Struct Context 

pub struct Context<A: Actor> {
    pub this: WeakActorRef<A>,
    /* private fields */
}

Actor execution context providing communication and spawning capabilities.

The Context is passed to actor methods and provides access to:

• Self reference for sending messages to itself via ctx.this.upgrade()
• Child actor management via ctx.spawn()
• Actor metadata via ctx.id()
• Lifecycle control via ctx.terminate()

Type Parameters

• A - The actor type this context belongs to

Fields

this: WeakActorRef<A>

Weak reference to this actor instance

Implementations

impl<A: Actor> Context<A>

pub fn id(&self) -> ActorId

Get the unique identifier of this actor.

Return

ActorId uniquely identifying this actor instance.

pub fn spawn<Args: ActorArgs>(&self, args: Args) -> ActorRef<Args::Actor>

Spawn a new child actor with the given arguments.

Arguments

• args - Initialization arguments for the new actor

Return

ActorRef<Args::Actor> reference to the newly spawned actor.

Panics

Panics if the internal child handle lock is poisoned.

pub async fn terminate(&self)

Terminate this actor and all its children.

Panics

Panics if the signal channel is unexpectedly closed.

Trait Implementations

impl<A: Actor> Clone for Context<A>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<A: Debug + Actor> Debug for Context<A>

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

Formats the value using the given formatter.

impl<A> PersistentContextExt<A> for Context<A>

where A: Actor + PersistentActor,

fn save_snapshot<S: PersistentStorage>( &self, storage: &S, state: &A, ) -> impl Future<Output = Result<()>> + Send

Save a snapshot of the actor’s current state to storage.

impl<A> PersistentSpawnExt for Context<A>

where A: Actor,

async fn spawn_persistent<S, Args>( &self, _storage: &S, actor_id: ActorId, args: Args, ) -> Result<ActorRef<Args::Actor>, PersistenceError>

where S: PersistentStorage, Args: ActorArgs, <Args as ActorArgs>::Actor: PersistentActor,

Spawn an actor with persistence support.

async fn respawn<S, B>( &self, storage: &S, actor_id: ActorId, runtime_args: B::RuntimeArgs, ) -> Result<ActorRef<B>, PersistenceError>

where S: PersistentStorage, B: Actor + PersistentActor,

Since it coerce the given Id to actor, it is callers’ responsibility to ensure no more than one actor is spawned with the same ID.Failure to do so will not result error immediately, but latened undefined behavior.It does not invoke PersistentContextExt::save_snapshot automatically, it should be specified in ActorArgs::initialize if needed.

async fn respawn_or<S, Args>( &self, storage: &S, actor_id: ActorId, runtime_args: impl FnOnce() -> <<Args as ActorArgs>::Actor as PersistentActor>::RuntimeArgs + Send, default_args: impl FnOnce() -> Args + Send, ) -> Result<ActorRef<Args::Actor>, PersistenceError>

where S: PersistentStorage, Args: ActorArgs, <Args as ActorArgs>::Actor: PersistentActor,

Since it coerce the given Id to actor, it is callers’ responsibility to ensure no more than one actor is spawned with the same ID.Failure to do so will not result error immediately, but latened undefined behavior.It does not invoke PersistentContextExt::save_snapshot automatically, it should be specified in ActorArgs::initialize if needed.