[−][src]Struct async_zmq::reply::Reply
The async wrapper of ZMQ socket with REP type
Methods
impl Reply[src]
pub async fn recv<'_>(&'_ self) -> Result<MessageBuf, Error>[src]
Receive request from REQ/DEALER socket. This should be the first method to be called, and then continue with receive/send pattern in synchronous way.
pub async fn send<'_, T: Into<MessageBuf>>(
&'_ self,
msg: T
) -> Result<(), Error>[src]
&'_ self,
msg: T
) -> Result<(), Error>
Send reply to REQ/DEALER socket. recv must be called first in order to reply.
pub fn as_raw_socket(&self) -> &Socket[src]
Represent as Socket from zmq crate in case you want to call its methods.
Trait Implementations
Auto Trait Implementations
impl RefUnwindSafe for Reply
impl Send for Reply
impl !Sync for Reply
impl Unpin for Reply
impl UnwindSafe for Reply
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized, [src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized, [src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized, [src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T[src]
impl<T> From<T> for T[src]
impl<T, U> Into<U> for T where
U: From<T>, [src]
U: From<T>,
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>,