Struct tokio_zmq::Sub

pub struct Sub { /* fields omitted */ }

The SUB SocketType wrapper type

Sub implements StreamSocket, and has an associated controlled variant.

Methods

impl Sub

fn controlled<S>(self, control: S) -> SubControlled where
    S: StreamSocket, 

Construct a controlled variant of the Sub socket

Trait Implementations

impl Clone for Sub

fn clone(&self) -> Sub

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl AsSocket for Sub

fn socket(&self) -> &Socket

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

fn into_socket(self) -> Socket

Any type implementing AsSocket must have a way of consuming itself and returning a socket.

impl StreamSocket for Sub

fn recv(&self) -> MultipartResponse

Receive a single multipart message from the socket.

fn stream(&self) -> MultipartStream<DefaultEndHandler>

Receive a stream of multipart messages from the socket.

fn stream_with_end<E>(&self, end_handler: E) -> MultipartStream<E> where
    E: EndHandler, 

Receive a stream of multipart messages from the socket ending when end_handler's should_stop returns true.

impl<'a> TryFrom<SubConfig<'a>> for Sub

type Error = Error

🔬 This is a nightly-only experimental API. (try_from)

The type returned in the event of a conversion error.

fn try_from(conf: SubConfig<'a>) -> Result<Self, Self::Error>

🔬 This is a nightly-only experimental API. (try_from)

Performs the conversion.