Struct TypedMailbox 

pub struct TypedMailbox<A: Actor + Send + Sync> { /* private fields */ }

Concrete Mailbox for a specific actor type A. Holds the channel sender to the actor’s run loop and performs the type-safe downcast on each send. Constructed in Actor::run_actor and erased to Arc<dyn Mailbox> for storage in the system’s actor map.

Implementations

impl<A: Actor + Send + Sync> TypedMailbox<A>

pub fn new(tx: Sender<Message<A>>) -> Self

Wrap an mpsc sender. Only called from Actor::run_actor.

Trait Implementations

impl<A> Mailbox for TypedMailbox<A>

where A: Actor + Send + Sync + 'static, A::Message: Any + Send + Sync + 'static, A::Result: Any + Send + 'static,

fn send<'life0, 'async_trait>( &'life0 self, msg: Arc<dyn Any + Send + Sync>, ) -> Pin<Box<dyn Future<Output = Result<(), ActorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Fire-and-forget send. Downcast the payload to A::Message and push it onto the actor’s mpsc channel.

fn send_and_recv<'life0, 'async_trait>( &'life0 self, msg: Arc<dyn Any + Send + Sync>, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn Any + Send>, ActorError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send and await the actor’s reply. The reply is returned as a boxed Any; the caller downcasts to A::Result.