Struct ActorRef 

pub struct ActorRef<M: Send + 'static> { /* private fields */ }

Typed handle to an actor.

Cheap to clone (internally Arc). tell sends without waiting; ask uses a helper pattern (ask_with) to avoid reflection.

Implementations

impl<M: Send + 'static> ActorRef<M>

pub fn from_remote( handle: Arc<dyn RemoteRef>, serialize: Arc<dyn Fn(M, Option<ActorPath>) -> SerializedMessage + Send + Sync>, ) -> Self

Construct a typed remote ref given a (type-erased) RemoteRef handle and a serializer for M. Used by atomr-remote::RemoteActorRefProvider.

pub fn path(&self) -> &ActorPath

pub fn is_remote(&self) -> bool

True if this ref points at an actor in a different ActorSystem.

pub fn tell(&self, msg: M)

Fire-and-forget send.

pub fn tell_from(&self, msg: M, sender: Sender)

Send msg with a typed Sender. The sender’s identity stays type-checked end-to-end (no Any::downcast on the reply path).

pub fn stop(&self)

Stop the actor.

pub async fn ask_with<R, F>( &self, build: F, timeout: Duration, ) -> Result<R, AskError>

where R: Send + 'static, F: FnOnce(Sender<R>) -> M,

Ask pattern: callers supply a closure that embeds a oneshot::Sender<R> in the message. The future resolves when the actor replies, or errors out on timeout/actor-stop.

Note: ask_with only works on local refs. For remote ask, use the dedicated atomr-remote::ask_remote helper which routes the reply through a temporary local responder actor.

pub fn as_untyped(&self) -> UntypedActorRef

Downgrade into an untyped ref for use with DeadLetters / EventStream.

Trait Implementations

impl<M: Send + 'static> Clone for ActorRef<M>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<M: Send + 'static> Debug for ActorRef<M>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<M: Send + 'static> From<&ActorRef<M>> for Sender

fn from(r: &ActorRef<M>) -> Self

Converts to this type from the input type.