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
20
21
22
23
24
25
26
27

use std::time::Duration;

use async_zmq::{reply, request, Message, Result};

#[async_std::test]
async fn publish_subscribe_message() -> Result<()> {
    let uri = "tcp://0.0.0.0:5555";
    let request = request(uri)?.connect()?;
    let reply = reply(uri)?.bind()?;
    let request_message = "Hello";
    let reply_message = "World";

    request.send(Message::from(request_message)).await?;

    async_std::task::sleep(Duration::from_millis(1000)).await;

    let recv = reply.recv().await?;
    assert_eq!(recv[0].as_str().unwrap(), request_message);
    reply.send(Message::from(reply_message)).await?;

    async_std::task::sleep(Duration::from_millis(1000)).await;

    let recv = request.recv().await?;
    assert_eq!(recv[0].as_str().unwrap(), reply_message);

    Ok(())
}