A client for NATS using tokio and async-await.
There are still features missing, but it should be ready for use in simple situations.
A client for NATS using tokio and async-await.
There are still features missing, but it should be ready for use in simple situations.
toml
[dependencies]
tokio-nats = "0.1.0"
```rust
use tokionats::{NatsConfigBuilder, connect}; use futuresutil::StreamExt; async fn demo() { let config = NatsConfigBuilder::default() .server("127.0.0.1:4222") .build() .unwrap(); let mut client = connect(config).await.unwrap(); client.publish("MySubject", "hello world".asbytes()).await.unwrap(); client.subscribe("MyOtherSubject").await.unwrap().foreach(async move |message| { println!("Received message {:?}", message); }).await; } ```