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
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54

use zmq::Context as ZmqContext;

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

/// Create a builder for a PUB socket.
///
/// ## Usage Example
///
/// ```rust,no_run
/// use tmq::{publish, Context, Result};
///
/// use futures::SinkExt;
/// use log::info;
/// use std::env;
/// use std::time::Duration;
/// use tokio::time::sleep;
///
/// #[tokio::main]
/// async fn main() -> Result<()> {
///
///     let mut socket = publish(&Context::new()).bind("tcp://127.0.0.1:7899")?;
///
///     let mut i = 0;
///
///     loop {
///         i += 1;
///
///         socket
///             .send(vec!["topic", &format!("Broadcast #{}", i)])
///             .await?;
///
///         sleep(Duration::from_secs(1)).await;
///     }
/// }
/// ```
pub fn publish(context: &ZmqContext) -> SocketBuilder<Publish> {
    SocketBuilder::new(context, zmq::SocketType::PUB)
}

/// Asynchronous PUB socket.
pub struct Publish {
    inner: Sender,
}

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

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