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

mod async_helpers;

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

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

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

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

    zeromq::proxy(frontend, backend, Some(Box::new(capture))).await?;
    Ok(())
}