zeromq 0.6.0-pre.1

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

mod async_helpers;

use std::convert::TryInto;
use std::error::Error;
use zeromq::{Socket, SocketRecv, SocketSend};

#[async_helpers::main]
async fn main() -> Result<(), Box<dyn Error>> {
    let mut socket = zeromq::RepSocket::new();
    socket
        .connect("tcp://127.0.0.1:5560")
        .await
        .expect("Failed to connect");

    loop {
        let mut repl: String = socket.recv().await?.try_into()?;
        println!("Received: {}", repl);
        repl.push_str(" Reply");
        socket.send(repl.into()).await?;
    }
}