tmq 0.5.0

ZeroMQ bindings for Tokio
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

use zmq::Context as ZmqContext;

use crate::{comm::Receiver, poll::ZmqPoller, FromZmqSocket, SocketBuilder};

/// Create a builder for a PULL socket.
pub fn pull(context: &ZmqContext) -> SocketBuilder<Pull> {
    SocketBuilder::new(context, zmq::SocketType::PULL)
}

/// Asynchronous PULL socket.
pub struct Pull {
    inner: Receiver,
}

impl FromZmqSocket<Pull> for Pull {
    fn from_zmq_socket(socket: zmq::Socket) -> crate::Result<Self> {
        Ok(Self {
            inner: Receiver::new(ZmqPoller::from_zmq_socket(socket)?),
        })
    }
}

impl_wrapper!(Pull, Receiver, inner);
impl_wrapper_stream!(Pull, inner);
impl_buffered!(Pull, inner);