Struct riker::actor::Context

pub struct Context<Msg: Message> {
    pub myself: ActorRef<Msg>,
    pub system: ActorSystem,
    // some fields omitted
}

Provides context, including the actor system during actor execution.

Context is passed to an actor's functions, such as receive.

Operations performed are in most cases done so from the actor's perspective. For example, creating a child actor using ctx.actor_of will create the child under the current actor within the heirarchy. In a similar manner, persistence operations such as persist_event use the current actor's persistence configuration.

Since Context is specific to an actor and its functions it is not cloneable.

Fields

myself: ActorRef<Msg>

system: ActorSystem

Methods

impl<Msg> Context<Msg> where
    Msg: Message, 

pub fn myself(&self) -> ActorRef<Msg>

Returns the ActorRef of the current actor.

Trait Implementations

impl<Msg: Message> ActorRefFactory for Context<Msg>

fn actor_of<A>(
    &self,
    props: BoxActorProd<A>,
    name: &str
) -> Result<ActorRef<A::Msg>, CreateError> where
    A: Actor, 

fn stop(&self, actor: impl ActorReference)

impl<Msg> ActorSelectionFactory for Context<Msg> where
    Msg: Message, 

fn select(&self, path: &str) -> Result<ActorSelection, InvalidPath>

impl<Msg> Run for Context<Msg> where
    Msg: Message, 

fn run<Fut>(
    &self,
    future: Fut
) -> Result<RemoteHandle<<Fut as Future>::Output>, SpawnError> where
    Fut: Future + Send + 'static,
    <Fut as Future>::Output: Send, 

impl<Msg> Timer for Context<Msg> where
    Msg: Message, 

fn schedule<T, M>(
    &self,
    initial_delay: Duration,
    interval: Duration,
    receiver: ActorRef<M>,
    sender: Sender,
    msg: T
) -> Uuid where
    T: Message + Into<M>,
    M: Message, 

fn schedule_once<T, M>(
    &self,
    delay: Duration,
    receiver: ActorRef<M>,
    sender: Sender,
    msg: T
) -> Uuid where
    T: Message + Into<M>,
    M: Message, 

fn schedule_at_time<T, M>(
    &self,
    time: DateTime<Utc>,
    receiver: ActorRef<M>,
    sender: Sender,
    msg: T
) -> Uuid where
    T: Message + Into<M>,
    M: Message, 

fn cancel_schedule(&self, id: Uuid)