Struct ThreadActorSystemHandle

pub struct ThreadActorSystemHandle { /* private fields */ }

Implementations

impl ThreadActorSystemHandle

pub fn new_actor_system( name: impl Into<String>, tokio: Option<Runtime>, join_tasks_on_drop: bool, ) -> Self

Owns the passed runtime, using it only if no contextual handle is available; if None is passed, it creates a runtime with multi-threaded support, CPU-based thread pool size and all features enabled.

pub fn spawn_thread_blocking_task(&self, f: impl FnOnce() + Send + 'static)

Trait Implementations

impl ActorSystemHandle for ThreadActorSystemHandle

type ActorRefT<MsgT> = ThreadActorRef<MsgT> where MsgT: ActorMsg

fn create<MsgT>( &self, node_id: impl Into<String>, name: impl Into<String>, join_on_drop: bool, ) -> Self::ActorRefT<MsgT>

where MsgT: ActorMsg,

impl Clone for ThreadActorSystemHandle

fn clone(&self) -> ThreadActorSystemHandle

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ThreadActorSystemHandle

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

Formats the value using the given formatter.

impl Joinable<()> for ThreadActorSystemHandle

fn join(&mut self)

impl Task for ThreadActorSystemHandle

fn is_finished(&self) -> bool