Struct tokio_zmq::socket::types::Xpub

pub struct Xpub { /* private fields */ }

The XPUB SocketType wrapper type

Xpub implements StreamSocket and SinkSocket, and has an associated controlled variant.

Trait Implementations

impl AsSocket for Xpub

fn socket(self) -> Socket

Any type implementing AsSocket must have a way of returning a reference to a Socket.

impl From<(Socket, PollEvented<ZmqFile>)> for Xpub

fn from(tup: (Socket, EventedFile)) -> Self

Converts to this type from the input type.

impl SinkSocket for Xpub

fn send(self, multipart: Multipart) -> MultipartRequest<Self>

Send a single multipart message to the socket.

fn sink(self, buffer_size: usize) -> MultipartSink

Send a stream of multipart messages to the socket.

impl StreamSocket for Xpub

fn recv(self) -> MultipartResponse<Self>

Receive a single multipart message from the socket.

fn stream(self) -> MultipartStream

Receive a stream of multipart messages from the socket.