Struct tokio_zmq::PairControlled

pub struct PairControlled { /* fields omitted */ }

The controlled variant of Pair

Trait Implementations

impl AsControlledSocket for PairControlled

fn socket(&self) -> &ControlledSocket

Any implementing type must have a method of getting a reference to the inner ControlledSocket.

impl<H> ControlledStreamSocket<H> for PairControlled where
    H: ControlHandler, 

fn recv(&self) -> MultipartResponse

Receive a single multipart message from the socket.

fn stream(&self, handler: H) -> ControlledStream<H>

Receive a stream of multipart messages from the socket.

impl ControlledSinkSocket for PairControlled

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

Send a single multipart message to the socket.

fn sink<E>(&self) -> MultipartSink<E> where
    E: From<Error>, 

Get a sink to send a stream of multipart messages to the socket.