Struct tokio_zmq::socket::Socket

pub struct Socket { /* fields omitted */ }

Defines the raw Socket type. This type should never be interacted with directly, except to create new instances of wrapper types.

Methods

impl Socket

pub fn builder(ctx: Arc<Context>) -> SocketBuilder<'static>

Start a new Socket Config builder

pub fn inner(self) -> (Socket, PollEvented<File<ZmqFile>>)

Retrieve a Reference-Counted Pointer to self's socket.

pub fn from_sock_and_file(     sock: Socket,     file: PollEvented<File<ZmqFile>> ) -> Self

Create a new socket from a given Sock and File

This assumes that sock is already configured properly. Please don't call this directly unless you know what you're doing.

pub fn sink(self) -> MultipartSink

Retrieve a Sink that consumes Multiparts, sending them to the socket

pub fn stream(self) -> MultipartStream

Retrieve a Stream that produces Multiparts, getting them from the socket

pub fn sink_stream(self) -> MultipartSinkStream

Retrieve a structure that is both a Stream that produces Multiparts and a Sink that consumes Multiparts.

pub fn send<T>(self, multipart: Multipart) -> MultipartRequest<T> where     T: From<(Socket, PollEvented<File<ZmqFile>>)>,

Retrieve a Future that consumes a multipart, sending it to the socket

pub fn recv<T>(self) -> MultipartResponse<T> where     T: From<(Socket, PollEvented<File<ZmqFile>>)>,

Retrieve a Future that produces a multipart, getting it fromthe socket

Trait Implementations

impl From<(Socket, PollEvented<File<ZmqFile>>)> for Socket

fn from((sock, file): (Socket, PollEvented<File<ZmqFile>>)) -> Self

Performs the conversion.