Struct Context 

pub struct Context<A>
where
    A: Actor<Context = Self>,
{ /* private fields */ }

The default implementation of an actor context.

Implementations

impl<A> Context<A>

where A: Actor<Context = Self>,

pub fn with_capacity(label: String, capacity: usize) -> Self

Constructs a new Context with a specific capacity.

pub fn with_channel( label: String, tx: Sender<Envelope<A>>, rx: Receiver<Envelope<A>>, ) -> Self

Constructs a new Context with a specific channel.

Trait Implementations

impl<A> ActorContext<A> for Context<A>

where A: Actor<Context = Self>,

fn new(label: String) -> Self

Constructs a new context.

fn index(&self) -> usize

Returns the index of the actor.

fn label(&self) -> &str

Returns the label of the actor.

fn address(&self) -> Address<A>

Returns the address of the actor.

fn take_mailbox(&mut self) -> Option<Mailbox<A>>

Returns the mailbox of the actor.

fn state(&self) -> ActorState

Returns the state of the actor.

fn set_state(&mut self, state: ActorState)

Sets the state of the actor.

fn supervisor(&self) -> Option<&Recipient<SupervisionEvent<A>>>

Returns the address of the supervisor.

fn set_supervisor(&mut self, supervisor: Option<Recipient<SupervisionEvent<A>>>)

Sets a supervisor.

async fn processing( &mut self, actor: &mut A, mailbox: Mailbox<A>, ) -> Result<(), A::Error>

Runs the main processing loop of the actor.

fn set_error(&mut self, error: A::Error)

Sets an error during message processing.

fn drain_mailbox(&mut self)

Drains the mailbox of the actor.

fn stop(&mut self)

Stops the actor.

fn stop_with_error(&mut self, error: A::Error)

Stops the actor and save the error for reporting.

fn terminate(&mut self)

Terminates the actor.

fn terminate_with_error(&mut self, error: A::Error)

Terminates the actor and save the error for reporting.

fn notify_supervisor( &mut self, event: SupervisionEvent<A>, ) -> impl Future<Output = ()> + Send

Notifies the supervisor for an event.

fn try_notify_supervisor(&mut self, event: SupervisionEvent<A>)

Notifies the supervisor for an event.

fn run( self, actor: A, span: Span, ) -> Result<(Address<A>, JoinHandle<()>), A::Error>

Starts the actor and returns its address and a join handle.

impl<A> Debug for Context<A>

where A: Actor<Context = Self> + Debug, A::Error: Debug,

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

Formats the value using the given formatter.