Struct tiny_tokio_actor::ActorSystem

pub struct ActorSystem<E: SystemEvent> { /* private fields */ }

Implementations

impl<E: SystemEvent> ActorSystem<E>

pub fn name(&self) -> &str

The name given to this actor system

pub fn publish(&self, event: E)

Publish an event on the actor system’s event bus. These events can be received by other actors in the same actor system.

pub fn events(&self) -> EventReceiver<E>

Subscribe to events of this actor system.

pub async fn get_actor<A: Actor<E>>(
    &self,
    path: &ActorPath
) -> Option<ActorRef<E, A>>

Retrieves an actor running in this actor system. If actor does not exist, a None is returned instead.

pub async fn create_actor<A: Actor<E>>(
    &self,
    name: &str,
    actor: A
) -> Result<ActorRef<E, A>, ActorError>

Launches a new top level actor on this actor system at the ‘/user’ actor path. If another actor with the same name already exists, an Err(ActorError::Exists(ActorPath)) is returned instead.

pub async fn get_or_create_actor<A, F>(
    &self,
    name: &str,
    actor_fn: F
) -> Result<ActorRef<E, A>, ActorError>where
    A: Actor<E>,
    F: FnOnce() -> A,

Retrieve or create a new actor on this actor system if it does not exist yet.

pub async fn stop_actor(&self, path: &ActorPath)

Stops the actor on this actor system. All its children will also be stopped.

pub fn new(name: &str, bus: EventBus<E>) -> Self

Creats a new actor system on which you can create actors.

Trait Implementations

impl<E: Clone + SystemEvent> Clone for ActorSystem<E>

fn clone(&self) -> ActorSystem<E>

Returns a copy of the value.

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

Performs copy-assignment from source.