Struct agner_actors::Context

pub struct Context<M> { /* private fields */ }

Actor’s API to itself

Implementations

impl<M> Context<M>

pub fn actor_id(&self) -> ActorID

Get current actor’s ActorID

pub fn system(&self) -> System

Get the System this actor is running in.

pub async fn next_event(&mut self) -> Event<M>where M: Unpin,

Receive next event (message or signal)

pub async fn next_message(&mut self) -> Mwhere M: Unpin,

Receive next message.

pub async fn next_signal(&mut self) -> Signal

Receive next signal.

pub async fn exit(&mut self, exit_reason: Exit) -> Never

Exit with the provided reason

pub async fn link(&mut self, to: ActorID)

Link this actor to another actor.

pub async fn unlink(&mut self, from: ActorID)

Unlink this actor from another actor.

pub async fn trap_exit(&mut self, trap_exit: bool)

Set whether this actor upon receiving a Signal will be able to handle it (trap_exit = true) or crash (trap_exit = false).

pub async fn future_to_inbox<F>(&mut self, fut: F)where F: Future + Send + Sync + 'static, F::Output: Into<M>,

Process the provided future “in background” and upon its completion send the output to the message-inbox.

impl<M> Context<M>

“data-bag” related methods

pub fn put<D>(&mut self, data: D) -> Option<D>where D: Any + Send + Sync + 'static,

pub fn take<D>(&mut self) -> Option<D>where D: Any + Send + Sync + 'static,

pub fn get<D>(&self) -> Option<&D>where D: Any + Send + Sync + 'static,

pub fn get_mut<D>(&mut self) -> Option<&mut D>where D: Any + Send + Sync + 'static,

pub fn with_data( self, data: HashMap<TypeId, Box<dyn Any + Send + Sync + 'static>> ) -> Self

Trait Implementations

impl<M: Debug> Debug for Context<M>

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

Formats the value using the given formatter.