Struct tonari_actor::System

pub struct System { /* private fields */ }

Systems are responsible for keeping track of their spawned actors, and managing their lifecycles appropriately.

You may run multiple systems in the same application, each system being responsible for its own pool of actors.

Implementations

impl System

pub fn new(name: &str) -> Self

Creates a new System with a given name.

pub fn with_callbacks(name: &str, callbacks: SystemCallbacks) -> Self

pub fn prepare<A>(&mut self, actor: A) -> SpawnBuilder<'_, A, impl FnOnce() -> A>where A: Actor + 'static,

Prepare an actor to be spawned. Returns a SpawnBuilder which can be used to customize the spawning of the actor.

pub fn prepare_fn<A, F>(&mut self, factory: F) -> SpawnBuilder<'_, A, F>where A: Actor + 'static, F: FnOnce() -> A + Send + 'static,

Similar to prepare, but an actor factory is passed instead of an Actor itself. This is used when an actor needs to be created on its own thread instead of the calling thread. Returns a SpawnBuilder which can be used to customize the spawning of the actor.

pub fn spawn<A>(&mut self, actor: A) -> Result<Addr<A>, ActorError>where A: Actor<Context = Context<<A as Actor>::Message>> + Send + 'static,

Spawn a normal Actor in the system, returning its address when successful.

pub fn run(&mut self) -> Result<(), ActorError>

Block the current thread until the system is shutdown.

Methods from Deref<Target = SystemHandle>

pub fn shutdown(&self) -> Result<(), ActorError>

Stops all actors spawned by this system.

pub fn subscribe_recipient<M: 'static, E: Event + Into<M>>( &self, recipient: Recipient<M> )

Subscribe given recipient to events of type E. See Context::subscribe().

pub fn publish<E: Event>(&self, event: E) -> Result<(), PublishError>

Publish an event. All actors that have previously subscribed to the type will receive it.

When sending to some subscriber fails, others are still tried and vec of errors is returned. For direct, non-Clone or high-throughput messages please use Addr or Recipient.

pub fn is_running(&self) -> bool

Trait Implementations

impl Default for System

fn default() -> System

Returns the “default value” for a type.

impl Deref for System

type Target = SystemHandle

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl Drop for System

fn drop(&mut self)

Executes the destructor for this type.