Struct futures_zmq::Pair

pub struct Pair { /* private fields */ }

The PAIR SocketType wrapper type.

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

Trait Implementations

impl<'a> Build<Pair> for PairConfig<'a>

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

impl From<Socket> for Pair

fn from(inner: Socket) -> Self

Converts to this type from the input type.

impl From<usize> for Pair

fn from(inner: usize) -> Self

Converts to this type from the input type.

impl IntoInnerSocket for Pair

type Socket = Socket

fn socket(self) -> Self::Socket

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

fn kind() -> SocketType

impl SinkSocket for Pair

fn send(
    self,
    multipart: Multipart
) -> <Self::Socket as InnerSocket<Self>>::Request

Send a single multipart message to the socket.

fn sink(self, buffer_size: usize) -> <Self::Socket as InnerSocket<Self>>::Sink

Send a stream of multipart messages to the socket.

impl StreamSocket for Pair

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.

impl Pair for Pair