Struct ActorSystem 

pub struct ActorSystem { /* private fields */ }

Implementations

impl ActorSystem

pub fn new(pools: Pools, clock: Clock) -> Self

pub fn testing(clock: Clock) -> Self

A scope over one process-wide set of worker threads and timer scheduler, held alive by the shared root so callers may drop it while the spawners they handed out keep working. A pool per fixture would spawn threads nothing joins and hit the OS per-process thread limit within one test binary.

pub fn scope(&self) -> Self

pub fn pools(&self) -> Pools

pub fn spawner(&self) -> ActorSpawner

pub fn cancellation_token(&self) -> CancellationToken

pub fn is_cancelled(&self) -> bool

pub fn shutdown(&self)

pub fn join(&self) -> Result<(), JoinError>

pub fn join_timeout(&self, timeout: Duration) -> Result<(), JoinError>

pub fn scheduler(&self) -> &SchedulerHandle

pub fn clock(&self) -> &Clock

pub fn spawn_coordination<A: Actor>( &self, name: &str, actor: A, ) -> ActorHandle<A::Message>

where A::State: Send,

pub fn spawn_flow<A: Actor>( &self, name: &str, actor: A, ) -> ActorHandle<A::Message>

where A::State: Send,

pub fn spawn_maintenance<A: Actor>( &self, name: &str, actor: A, ) -> ActorHandle<A::Message>

where A::State: Send,

pub fn spawn_ephemeral<A: Actor>( &self, name: &str, actor: A, ) -> ActorHandle<A::Message>

where A::State: Send,

Trait Implementations

impl Clone for ActorSystem

fn clone(&self) -> ActorSystem

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ActorSystem

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

Formats the value using the given formatter.