Struct ActorCell 

pub struct ActorCell { /* private fields */ }

Main interface for interractiong with an Actor for the internals.

Implementations

impl ActorCell

pub fn new( props: Arc<dyn ActorFactory>, system: ActorSystem, father: ActorRef, path: Arc<ActorPath>, ) -> ActorCell

Creates a new ActorCell.

pub fn receive_message(&self, message: InnerMessage, sender: ActorRef)

Puts a message with its sender in the Actor’s mailbox and schedules the Actor.

pub fn receive_system_message(&self, system_message: SystemMessage)

Puts a system message with its sender in the Actor’s system mailbox and schedules the Actor.

pub fn handle_envelope(&self)

Makes the Actor handle an envelope in its mailbox.

Trait Implementations

impl ActorContext for ActorCell

fn actor_ref(&self) -> ActorRef

Returns an ActorRef to the Actor.

fn actor_of( &self, props: Arc<dyn ActorFactory>, name: String, ) -> Result<ActorRef, &'static str>

Spawns a child actor.

fn tell<MessageTo: Message>(&self, to: ActorRef, message: MessageTo)

Sends a Message to the targeted ActorRef.

fn ask<MessageTo: Message>( &self, to: ActorRef, message: MessageTo, name: String, ) -> ActorRef

Creates a Future, this Future will send the message to the targetted ActorRef (and thus be the sender of the message).

fn complete<MessageTo: Message>(&self, future: ActorRef, complete: MessageTo)

Completes a Future.

fn forward_result<T: Message>(&self, future: ActorRef, actor: ActorRef)

Tells a future to forward its result to another Actor. The Future is then dropped.

fn forward_result_to_future<T: Message>( &self, future: ActorRef, actor: ActorRef, )

Tells a future to forward its result to another Future that will be completed with this result. The Future is then dropped.

fn do_computation<T: Message, F: Fn(Box<dyn Any + Send>, ActorCell) -> T + Send + Sync + 'static>( &self, future: ActorRef, closure: F, )

Sends the Future a closure to apply on its value, the value will be updated with the output of the closure.

fn sender(&self) -> ActorRef

Returns an Arc to the sender of the message being handled.

fn tell_control(&self, actor: ActorRef, message: ControlMessage)

Sends a control message to the given actor.

fn stop(&self, actor_ref: ActorRef)

Requests the targeted actor to stop.

fn kill_me(&self)

Asks the father of the actor to terminate it.

fn father(&self) -> ActorRef

Father of the actor.

fn children(&self) -> HashMap<Arc<ActorPath>, ActorRef>

Children of the actor.

fn monitoring(&self) -> HashMap<Arc<ActorPath>, (ActorRef, FailureHandler)>

Lifecycle monitoring, list of monitored actors.

fn monitored_by(&self) -> Vec<ActorRef>

Actors monitoring this actor.

fn monitor(&self, actor: ActorRef, handler: FailureHandler)

Monitor an actor with the given handler.

fn path(&self) -> Arc<ActorPath>

Logical path to the actor, such as /user/foo/bar/baz

fn identify_actor(&self, name: String, request_name: String) -> ActorRef

Future containing an Option with an ActtorRef to the Actor with the given logical path.

fn fail(&self, reason: &'static str)

Puts the actor in a state of failure with the given reason.

impl Clone for ActorCell

fn clone(&self) -> ActorCell

Returns a duplicate of the value.

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

Performs copy-assignment from source.