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

use zmq::Context as ZmqContext;

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

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

/// Asynchronous PUSH socket.
pub struct Push {
    inner: Sender,
}

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

impl_wrapper!(Push, Sender, inner);
impl_wrapper_sink!(Push, inner);