async_zmq 0.4.0

Async version for ZeroMQ bindings
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

//! cargo run --example reply --features="rt-tokio" --no-default-features

use async_zmq::Result;
use futures::StreamExt;
use std::ops::Deref;

#[tokio::main]
async fn main() -> Result<()> {
    let mut zmq = async_zmq::reply("tcp://127.0.0.1:5555")?.bind()?;

    while let Some(msg) = zmq.next().await {
        for it in msg.unwrap().deref() {
            println!("message: {:?}", it.as_str());
        }
        zmq.send(vec!["Response for You"]).await?;
    }

    Ok(())
}