Struct 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) -> SockId

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

pub fn from_sock_and_session(sock: SockId, session: LocalSession) -> 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.

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<(SockId, LocalSession)> for Socket

fn from((sock, session): (SockId, LocalSession)) -> 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 Socket

where 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