Start of a consumer example
This commit is contained in:
parent
a786f4b79b
commit
8dbbfd922a
|
@ -0,0 +1,12 @@
|
|||
use syndicate::{packets, value::Value};
|
||||
use tokio::net::TcpStream;
|
||||
use tokio_util::codec::Framed;
|
||||
use futures::SinkExt;
|
||||
|
||||
#[tokio::main]
|
||||
async fn main() -> Result<(), Box<dyn std::error::Error>> {
|
||||
let mut frames = Framed::new(TcpStream::connect("127.0.0.1:8001").await?,
|
||||
packets::Codec::<packets::Out, packets::In>::standard());
|
||||
frames.send(packets::In::Connect(Value::from("producer-consumer-example").wrap())).await?;
|
||||
Ok(())
|
||||
}
|
Loading…
Reference in New Issue