Struct futures_zmq::Socket
source · pub struct Socket { /* private fields */ }
Expand description
Defines the raw Socket type. This type should never be interacted with directly, except to create new instances of wrapper types.
Implementations
sourceimpl Socket
impl Socket
sourcepub fn builder<T>(ctx: Arc<Context>) -> SocketBuilder<'static, T>where
T: IntoInnerSocket,
pub fn builder<T>(ctx: Arc<Context>) -> SocketBuilder<'static, T>where
T: IntoInnerSocket,
Start a new Socket Config builder
sourcepub fn from_sock_and_session(sock: SockId, session: LocalSession) -> Self
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
sourceimpl<T> InnerSocket<T> for Socketwhere
T: IntoInnerSocket + From<Self>,
impl<T> InnerSocket<T> for Socketwhere
T: IntoInnerSocket + From<Self>,
type Request = MultipartRequest<T>
type Request = MultipartRequest<T>
The future that sends a multipart to a ZMQ socket
type Response = MultipartResponse<T>
type Response = MultipartResponse<T>
The future that receives a multipart from a ZMQ socket
type Sink = MultipartSink<T>
type Sink = MultipartSink<T>
A Sink that sends multiparts to a ZMQ socket
type Stream = MultipartStream<T>
type Stream = MultipartStream<T>
A Stream of multiparts received from a ZMQ socket
type SinkStream = MultipartSinkStream<T>
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
sourceimpl<T> IntoSocket<T, Socket> for MultipartSink<T>where
T: From<Socket>,
impl<T> IntoSocket<T, Socket> for MultipartSink<T>where
T: From<Socket>,
fn into_socket(self) -> T
sourceimpl<T> IntoSocket<T, Socket> for MultipartSinkStream<T>where
T: From<Socket>,
impl<T> IntoSocket<T, Socket> for MultipartSinkStream<T>where
T: From<Socket>,
fn into_socket(self) -> T
sourceimpl<T> IntoSocket<T, Socket> for MultipartStream<T>where
T: From<Socket>,
impl<T> IntoSocket<T, Socket> for MultipartStream<T>where
T: From<Socket>,
fn into_socket(self) -> T
Auto Trait Implementations
impl RefUnwindSafe for Socket
impl Send for Socket
impl !Sync for Socket
impl Unpin for Socket
impl UnwindSafe for Socket
Blanket Implementations
sourceimpl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more