Trait TellHandler

Source

pub trait TellHandler<M: Send + 'static>: Send + Sync {
    // Required methods
    fn tell(&self, msg: M) -> BoxFuture<'_, Result<()>>;
    fn tell_with_timeout(
        &self,
        msg: M,
        timeout: Duration,
    ) -> BoxFuture<'_, Result<()>>;
    fn blocking_tell(&self, msg: M, timeout: Option<Duration>) -> Result<()>;
    fn clone_boxed(&self) -> Box<dyn TellHandler<M>>;
    fn downgrade(&self) -> Box<dyn WeakTellHandler<M>>;
    fn as_control(&self) -> &dyn ActorControl;
    fn debug_fmt(&self, f: &mut Formatter<'_>) -> Result;
}

Expand description

Fire-and-forget message handler for strong references (object-safe).

This trait allows storing different actor types that handle the same message type in a unified collection. The handlers maintain strong references to actors, keeping them alive.

§Example

let handlers: Vec<Box<dyn TellHandler<MyMessage>>> = vec![
    (&actor_a).into(),
    (&actor_b).into(),
];

for handler in &handlers {
    handler.tell(MyMessage { data: 42 }).await?;
}

Required Methods§

Source

fn tell(&self, msg: M) -> BoxFuture<'_, Result<()>>

Sends a message without waiting for a reply.

Source

fn tell_with_timeout( &self, msg: M, timeout: Duration, ) -> BoxFuture<'_, Result<()>>

Sends a message with timeout.

Source

fn blocking_tell(&self, msg: M, timeout: Option<Duration>) -> Result<()>

Blocking version of tell.

§Timeout Behavior

timeout: None: Uses Tokio’s blocking_send directly. Most efficient but blocks indefinitely.
timeout: Some(duration): Spawns a separate thread with a temporary runtime. Has overhead (~50-200μs for thread + ~1-10μs for runtime) but guarantees bounded waiting.

Source