Struct ractor::port::RpcReplyPort
source · pub struct RpcReplyPort<TMsg> { /* private fields */ }
Expand description
A remote procedure call’s reply port. Wrapper of concurrency::OneshotSender with a consistent error type
Implementations§
source§impl<TMsg> RpcReplyPort<TMsg>
impl<TMsg> RpcReplyPort<TMsg>
sourcepub fn get_timeout(&self) -> Option<Duration>
pub fn get_timeout(&self) -> Option<Duration>
Read the timeout of this RPC reply port
Returns [Some(concurrency::Duration)] if a timeout is set, None otherwise
sourcepub fn send(self, msg: TMsg) -> Result<(), MessagingErr<TMsg>>
pub fn send(self, msg: TMsg) -> Result<(), MessagingErr<TMsg>>
Send a message to the Rpc reply port. This consumes the port
msg
- The message to send
Returns [Ok(())] if the message send was successful, [Err(MessagingErr)] otherwise
Trait Implementations§
source§impl<TMsg: Debug> Debug for RpcReplyPort<TMsg>
impl<TMsg: Debug> Debug for RpcReplyPort<TMsg>
source§impl<TMsg> From<(Sender<TMsg>, Duration)> for RpcReplyPort<TMsg>
impl<TMsg> From<(Sender<TMsg>, Duration)> for RpcReplyPort<TMsg>
source§fn from((value, timeout): (OneshotSender<TMsg>, Duration)) -> Self
fn from((value, timeout): (OneshotSender<TMsg>, Duration)) -> Self
Converts to this type from the input type.
source§impl<TMsg> From<Sender<TMsg>> for RpcReplyPort<TMsg>
impl<TMsg> From<Sender<TMsg>> for RpcReplyPort<TMsg>
source§fn from(value: OneshotSender<TMsg>) -> Self
fn from(value: OneshotSender<TMsg>) -> Self
Converts to this type from the input type.
Auto Trait Implementations§
impl<TMsg> Freeze for RpcReplyPort<TMsg>
impl<TMsg> !RefUnwindSafe for RpcReplyPort<TMsg>
impl<TMsg> Send for RpcReplyPort<TMsg>where
TMsg: Send,
impl<TMsg> Sync for RpcReplyPort<TMsg>where
TMsg: Send,
impl<TMsg> Unpin for RpcReplyPort<TMsg>
impl<TMsg> !UnwindSafe for RpcReplyPort<TMsg>
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> Message for T
impl<T> Message for T
source§fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
Convert a BoxedMessage to this concrete type
source§fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
Convert this message to a BoxedMessage