Struct SpawnManagerActor 

pub struct SpawnManagerActor { /* private fields */ }

Native coerce actor wrapping SpawnManager.

Implementations

impl SpawnManagerActor

pub fn new( node_id: NodeId, registry: TypeRegistry, next_local: Arc<AtomicU64>, ) -> Self

Create a new SpawnManagerActor.

Trait Implementations

impl Actor for SpawnManagerActor

fn new_context( &self, system: Option<ActorSystem>, status: ActorStatus, boxed_ref: BoxedActorRef, ) -> ActorContext

Creates a new ActorContext, allowing actor implementations to override specific parts of the ActorContext, before the actor is started.

fn started<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 mut ActorContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Called once the Actor has been started

fn stopped<'life0, 'life1, 'async_trait>( &'life0 mut self, _ctx: &'life1 mut ActorContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

Called once the Actor has stopped

fn on_child_stopped<'life0, 'life1, 'life2, 'async_trait>( &'life0 mut self, _id: &'life1 Arc<str>, _ctx: &'life2 mut ActorContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, Self: 'async_trait,

Called when a supervised actor has stopped

fn actor_ref(&self, ctx: &ActorContext) -> LocalActorRef<Self>

where Self: Sized,

Returns a LocalActorRef<Self> instance of the current actor, automatically casting from the ActorContext’s BoxedActorRef.

fn type_name() -> &'static str

where Self: Sized,

Returns the actor’s type name string

fn tags(&self, ctx: &ActorContext) -> ActorTags

const DEFAULT_TAGS: ActorTags = { ActorTags::None }

Default tags used when creating the actor

impl Handler<GetSpawnedActors> for SpawnManagerActor

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, _msg: GetSpawnedActors, _ctx: &'life1 mut ActorContext, ) -> Pin<Box<dyn Future<Output = Vec<ActorId>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl Handler<HandleSpawnRequest> for SpawnManagerActor

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, msg: HandleSpawnRequest, _ctx: &'life1 mut ActorContext, ) -> Pin<Box<dyn Future<Output = SpawnOutcome> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

impl Handler<RegisterFactory> for SpawnManagerActor

fn handle<'life0, 'life1, 'async_trait>( &'life0 mut self, msg: RegisterFactory, _ctx: &'life1 mut ActorContext, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,