Struct tokio_zmq::Socket

pub struct Socket { /* private fields */ }

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

Implementations

impl Socket

pub fn builder<T>(ctx: Arc<Context>) -> SocketBuilder<'static, T>where
    T: IntoInnerSocket,

Start a new Socket Config builder

pub fn inner(self) -> (Socket, EventedFile)

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

pub fn from_sock_and_file(sock: Socket, file: EventedFile) -> 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 from_sock(sock: Socket) -> Result<Self, Error>

Create a new socket from a given Sock

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

Trait Implementations

impl Debug for Socket

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

Formats the value using the given formatter.

impl Display for Socket

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

Formats the value using the given formatter.

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

fn from((sock, file): (Socket, EventedFile)) -> Self

Converts to this type from the input type.

impl From<Socket> for Dealer

fn from(inner: Socket) -> Self

Converts to this type from the input type.

impl From<Socket> for Pair

fn from(inner: Socket) -> Self

Converts to this type from the input type.

impl From<Socket> for Pub

fn from(inner: Socket) -> Self

Converts to this type from the input type.

impl From<Socket> for Pull

fn from(inner: Socket) -> Self

Converts to this type from the input type.

impl From<Socket> for Push

fn from(inner: Socket) -> Self

Converts to this type from the input type.

impl From<Socket> for Rep

fn from(inner: Socket) -> Self

Converts to this type from the input type.

impl From<Socket> for Req

fn from(inner: Socket) -> Self

Converts to this type from the input type.

impl From<Socket> for Router

fn from(inner: Socket) -> Self

Converts to this type from the input type.

impl From<Socket> for Sub

fn from(inner: Socket) -> Self

Converts to this type from the input type.

impl From<Socket> for Xpub

fn from(inner: Socket) -> Self

Converts to this type from the input type.

impl From<Socket> for Xsub

fn from(inner: Socket) -> Self

Converts to this type from the input type.

impl<T> InnerSocket<T> for Socketwhere
    T: IntoInnerSocket + From<Self>,

type Request = MultipartRequest<T>

The future that sends a multipart to a ZMQ socket

type Response = MultipartResponse<T>

The future that receives a multipart from a ZMQ socket

type Sink = MultipartSink<T>

A Sink that sends multiparts to a ZMQ socket

type Stream = MultipartStream<T>

A Stream of multiparts received from a ZMQ socket

type SinkStream = MultipartSinkStream<T>

A Sink and Stream that sends and receives multiparts from a ZMQ socket

fn send(self, multipart: Multipart) -> Self::Request

fn recv(self) -> Self::Response

fn stream(self) -> Self::Stream

fn sink(self, buffer_size: usize) -> Self::Sink

fn sink_stream(self, buffer_size: usize) -> Self::SinkStream

impl<T> IntoSocket<T, Socket> for MultipartSink<T>where
    T: From<Socket>,

fn into_socket(self) -> T

impl<T> IntoSocket<T, Socket> for MultipartSinkStream<T>where
    T: From<Socket>,

fn into_socket(self) -> T

impl<T> IntoSocket<T, Socket> for MultipartStream<T>where
    T: From<Socket>,

fn into_socket(self) -> T