Module async_zmq::reply

REP socket module of Request-reply pattern in ZMQ

Use reply function to instantiate a REP socket.

Example

use async_zmq::Result;

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

    let msg = zmq.recv().await?;
    zmq.send(vec!["broadcast message"]).await?;
    Ok(())
}

Structs

Reply

The async wrapper of ZMQ socket with REP type

Functions

reply

Create a ZMQ socket with REP type