Struct ockam_node::Mailbox [−][src]
pub struct Mailbox { /* fields omitted */ }A mailbox for encoded messages
Message type information can’t be exposed at this stage because
they need to either be typed in the Relay or in the worker’s
Context.
Implementations
impl Mailbox[src]
pub fn new(rx: Receiver<RelayMessage>, tx: Sender<RelayMessage>) -> Self[src]
pub fn sender(&self) -> Sender<RelayMessage>[src]
pub async fn next(&mut self) -> Option<RelayMessage>[src]
Get the next message from the mailbox
pub async fn requeue(&self, msg: RelayMessage)[src]
If a message wasn’t expected, requeue it
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for Mailbox
impl Send for Mailbox
impl Sync for Mailbox
impl Unpin for Mailbox
impl !UnwindSafe for Mailbox
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,
pub fn borrow_mut(&mut self) -> &mut T[src]
impl<T> From<T> for T[src]
impl<T> Instrument for T[src]
pub fn instrument(self, span: Span) -> Instrumented<Self>[src]
pub fn in_current_span(self) -> Instrumented<Self>[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.
pub 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.
pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,