Struct futures_zmq::Sub

pub struct Sub { /* fields omitted */ }

The SUB SocketType wrapper type

Sub implements StreamSocket, and has an associated controlled variant.

Trait Implementations

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

fn build(self) -> Box<dyn Future<Item = Sub, Error = Error> + Send>

impl From<Socket> for Sub

fn from(inner: Socket) -> Self

Performs the conversion.

impl From<(SockId, LocalSession)> for Sub

fn from(inner: (SockId, LocalSession)) -> Self

Performs the conversion.

impl Debug for Sub

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.

impl IntoInnerSocket for Sub

type Socket = Socket

fn socket(self) -> Self::Socket

Any type implementing IntoInnerSocket must have a way of returning an InnerSocket.

fn kind() -> SocketType

impl UnPair for Sub

impl Sub for Sub

impl StreamSocket for Sub

fn recv(self) -> <Self::Socket as InnerSocket<Self>>::Response

Receive a single multipart message from the socket.

fn stream(self) -> <Self::Socket as InnerSocket<Self>>::Stream

Receive a stream of multipart messages from the socket.