Struct mailbox_processor::MailboxProcessor
source · [−]pub struct MailboxProcessor<Msg, ReplyMsg> { /* private fields */ }
Implementations
sourceimpl<Msg: Send + 'static, ReplyMsg: Send + 'static> MailboxProcessor<Msg, ReplyMsg>
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>
Auto Trait Implementations
impl<Msg, ReplyMsg> RefUnwindSafe for MailboxProcessor<Msg, ReplyMsg>
impl<Msg, ReplyMsg> Send for MailboxProcessor<Msg, ReplyMsg> where
Msg: Send,
ReplyMsg: Send,
impl<Msg, ReplyMsg> Sync for MailboxProcessor<Msg, ReplyMsg> where
Msg: Send,
ReplyMsg: Send,
impl<Msg, ReplyMsg> Unpin for MailboxProcessor<Msg, ReplyMsg>
impl<Msg, ReplyMsg> UnwindSafe for MailboxProcessor<Msg, ReplyMsg>
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcepub fn borrow_mut(&mut self) -> &mut T
pub fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more