Struct futures_zmq::Pub

pub struct Pub { /* fields omitted */ }

The PUB SocketType wrapper type

Pub implements SinkSocket.

Trait Implementations

impl From<Socket> for Pub

fn from(inner: Socket) -> Self

Performs the conversion.

impl From<(SockId, LocalSession)> for Pub

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

Performs the conversion.

impl Debug for Pub

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

Formats the value using the given formatter.

impl IntoInnerSocket for Pub

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 Pub

impl SinkSocket for Pub

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.