Use syndicate-macros a little more

This commit is contained in:
Tony Garnock-Jones 2021-08-13 00:02:05 -04:00
parent 5bb665ef62
commit 2255a54f1a
2 changed files with 2 additions and 31 deletions

View File

@ -6,11 +6,8 @@ use structopt::StructOpt;
use syndicate::actor::*;
use syndicate::relay;
use syndicate::schemas::dataspace::Observe;
use syndicate::schemas::dataspace_patterns as p;
use syndicate::sturdy;
use syndicate::value::Map;
use syndicate::value::NestedValue;
use syndicate::value::Value;
use tokio::net::TcpStream;
@ -47,20 +44,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
})
.create_cap(t.state);
ds.assert(t, &Observe {
pattern: p::Pattern::DCompound(Box::new(p::DCompound::Rec {
ctor: Box::new(p::CRec {
label: Value::symbol("Says").wrap(),
arity: 2.into(),
}),
members: Map::from_iter(vec![
(0.into(), p::Pattern::DBind(Box::new(p::DBind {
pattern: p::Pattern::DDiscard(Box::new(p::DDiscard)),
}))),
(1.into(), p::Pattern::DBind(Box::new(p::DBind {
pattern: p::Pattern::DDiscard(Box::new(p::DDiscard)),
}))),
].into_iter()),
})),
pattern: syndicate_macros::pattern!("<Says $ $>"),
observer: Arc::clone(&consumer),
});

View File

@ -6,11 +6,8 @@ use structopt::StructOpt;
use syndicate::actor::*;
use syndicate::relay;
use syndicate::schemas::dataspace::Observe;
use syndicate::schemas::dataspace_patterns as p;
use syndicate::sturdy;
use syndicate::value::Map;
use syndicate::value::NestedValue;
use syndicate::value::Value;
use tokio::net::TcpStream;
@ -68,17 +65,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
};
ds.assert(t, &Observe {
pattern: p::Pattern::DCompound(Box::new(p::DCompound::Rec {
ctor: Box::new(p::CRec {
label: Value::symbol("Present").wrap(),
arity: 1.into(),
}),
members: Map::from_iter(vec![
(0.into(), p::Pattern::DBind(Box::new(p::DBind {
pattern: p::Pattern::DDiscard(Box::new(p::DDiscard)),
}))),
].into_iter()),
})),
pattern: syndicate_macros::pattern!("<Present $>"),
observer: Arc::clone(&consumer),
});