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
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74

use crate::{
    poll::{ReceiverBuffer, ZmqPoller},
    Multipart,
};

type Poller = ZmqPoller;

/// Sends multiparts using an owned Poller.
pub struct Sender {
    pub(crate) poller: Poller,
    pub(crate) buffer: Multipart,
}
impl_as_socket!(Sender, poller);
impl_sink!(Sender, buffer, poller);

impl Sender {
    pub(crate) fn new(poller: Poller) -> Self {
        Self {
            poller,
            buffer: Default::default(),
        }
    }
}

/// Receives multiparts using an owned Poller.
pub struct Receiver {
    pub(crate) poller: Poller,
}
impl_as_socket!(Receiver, poller);
impl_stream!(Receiver, poller);

impl Receiver {
    pub(crate) fn new(poller: Poller) -> Self {
        Self { poller }
    }
    pub fn buffered(self, capacity: usize) -> BufferedReceiver {
        BufferedReceiver::new(self.poller, capacity)
    }
}

/// Receives buffered multiparts using an owned Poller.
pub struct BufferedReceiver {
    pub(crate) poller: Poller,
    pub(crate) buffer: ReceiverBuffer,
}
impl_as_socket!(BufferedReceiver, poller);
impl_buffered_stream!(BufferedReceiver, buffer, poller);

impl BufferedReceiver {
    pub(crate) fn new(poller: Poller, capacity: usize) -> Self {
        Self {
            poller,
            buffer: ReceiverBuffer::new(capacity),
        }
    }
}

/// Sends ands receives multiparts using an owned Poller.
pub struct SenderReceiver {
    pub(crate) poller: Poller,
    pub(crate) buffer: Multipart,
}
impl_as_socket!(SenderReceiver, poller);
impl_sink!(SenderReceiver, buffer, poller);
impl_stream!(SenderReceiver, poller);

impl SenderReceiver {
    pub(crate) fn new(poller: Poller) -> Self {
        Self {
            poller,
            buffer: Default::default(),
        }
    }
}