Struct Mailbox

pub struct Mailbox<T> { /* private fields */ }

Represents a destination for responses

Implementations

impl<T> Mailbox<T>

pub fn id(&self) -> &Id

Represents id associated with the mailbox

pub fn try_next(&mut self) -> Result<T, MailboxTryNextError>

Tries to receive the next value in mailbox without blocking or waiting async

pub async fn next(&mut self) -> Option<T>

Receives next value in mailbox

pub async fn next_timeout(&mut self, duration: Duration) -> Result<Option<T>>

Receives next value in mailbox, waiting up to duration before timing out

pub fn close(&mut self)

Closes the mailbox such that it will not receive any more values

Any values already in the mailbox will still be returned via next

impl<T: Send + 'static> Mailbox<T>

pub fn map<U: Send + 'static>( self, f: impl Fn(T) -> U + Send + Sync + 'static, ) -> Mailbox<U>

Maps the results of each mailbox value into a new type U

pub fn map_opt<U: Send + 'static>( self, f: impl Fn(T) -> Option<U> + Send + Sync + 'static, ) -> Mailbox<U>

Maps the results of each mailbox value into a new type U by returning an Option<U> where the option is None in the case that T cannot be converted into U