[−][src]Struct tokio_zmq::Socket
Defines the raw Socket type. This type should never be interacted with directly, except to create new instances of wrapper types.
Methods
impl Socket
[src]
pub fn builder<T>(ctx: Arc<Context>) -> SocketBuilder<'static, T> where
T: IntoInnerSocket,
[src]
T: IntoInnerSocket,
Start a new Socket Config builder
pub fn inner(self) -> (Socket, EventedFile)
[src]
Retrieve a Reference-Counted Pointer to self's socket.
pub fn from_sock_and_file(sock: Socket, file: EventedFile) -> Self
[src]
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>
[src]
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 From<Socket> for Dealer
[src]
impl From<Socket> for Pair
[src]
impl From<Socket> for Pub
[src]
impl From<Socket> for Pull
[src]
impl From<Socket> for Push
[src]
impl From<Socket> for Rep
[src]
impl From<Socket> for Req
[src]
impl From<Socket> for Router
[src]
impl From<Socket> for Sub
[src]
impl From<Socket> for Xpub
[src]
impl From<Socket> for Xsub
[src]
impl From<(Socket, PollEvented<ZmqFile>)> for Socket
[src]
impl Debug for Socket
[src]
impl Display for Socket
[src]
impl<T> IntoSocket<T, Socket> for MultipartSink<T> where
T: From<Socket>,
[src]
T: From<Socket>,
fn into_socket(self) -> T
[src]
impl<T> IntoSocket<T, Socket> for MultipartSinkStream<T> where
T: From<Socket>,
[src]
T: From<Socket>,
fn into_socket(self) -> T
[src]
impl<T> IntoSocket<T, Socket> for MultipartStream<T> where
T: From<Socket>,
[src]
T: From<Socket>,
fn into_socket(self) -> T
[src]
impl<T> InnerSocket<T> for Socket where
T: IntoInnerSocket + From<Self>,
[src]
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
[src]
fn recv(self) -> Self::Response
[src]
fn stream(self) -> Self::Stream
[src]
fn sink(self, buffer_size: usize) -> Self::Sink
[src]
fn sink_stream(self, buffer_size: usize) -> Self::SinkStream
[src]
Auto Trait Implementations
Blanket Implementations
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> ToString for T where
T: Display + ?Sized,
[src]
T: Display + ?Sized,
impl<T> From<T> for T
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,