zeromq 0.6.0

A native Rust implementation of ZeroMQ
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

mod async_helpers;
use std::error::Error;
use zeromq::prelude::*;

#[async_helpers::main]
async fn main() -> Result<(), Box<dyn Error>> {
    println!("Start forwarder");
    let mut frontend = zeromq::SubSocket::new();
    frontend.bind("tcp://127.0.0.1:30001").await?;

    let mut backend = zeromq::PubSocket::new();
    backend.bind("tcp://127.0.0.1:30002").await?;

    frontend.subscribe("").await?;

    let forward = async move {
        loop {
            let message = frontend.recv().await.unwrap();
            println!("passing message: {:?}", message);
            backend.send(message).await.unwrap();
        }
    };

    forward.await;

    Ok(())
}