Trait tokio_zmq::socket::ControlledStreamSocket
[−]
[src]
pub trait ControlledStreamSocket<H>: AsControlledSocket where
H: ControlHandler, { fn recv(&self) -> MultipartResponse { ... } fn stream(&self, handler: H) -> ControlledStream<H> { ... } }
This trait is used for types wrapping ControlledSocket
s. It depends on the type implementing
AsControlledSocket, which is analogous to the AsSocket
trait's socket(&self)
method.
Provided Methods
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.
Implementors
impl<H> ControlledStreamSocket<H> for DealerControlled where
H: ControlHandler,impl<H> ControlledStreamSocket<H> for PairControlled where
H: ControlHandler,impl<H> ControlledStreamSocket<H> for PullControlled where
H: ControlHandler,impl<H> ControlledStreamSocket<H> for RepControlled where
H: ControlHandler,impl<H> ControlledStreamSocket<H> for RouterControlled where
H: ControlHandler,impl<H> ControlledStreamSocket<H> for SubControlled where
H: ControlHandler,impl<H> ControlledStreamSocket<H> for XpubControlled where
H: ControlHandler,impl<H> ControlledStreamSocket<H> for XsubControlled where
H: ControlHandler,