Struct MailboxProcessor 

pub struct MailboxProcessor<Msg, ReplyMsg> { /* private fields */ }

Implementations

impl<Msg: Send + 'static, ReplyMsg: Send + 'static> MailboxProcessor<Msg, ReplyMsg>

pub async fn new<State: Send + 'static, F: Future<Output = State> + Send>( buffer_size: BufferSize, initial_state: State, message_processing_function: impl Fn(Msg, State, Option<Sender<ReplyMsg>>) -> F + Send + 'static + Sync, ) -> Self

pub async fn send(&self, msg: Msg) -> Result<ReplyMsg, MailboxProcessorError>

pub async fn fire_and_forget( &self, msg: Msg, ) -> Result<(), MailboxProcessorError>