Struct FixedSupervisor 

pub struct FixedSupervisor<Role, Worker, Plan, Source, DiagnosticRoute, LifecycleRoute>
where
    Role: Send + Sync,
    Source: WorkerSource<Role, Worker, Plan>,
    Worker: Behavior + Send,
    Plan: ActivationPlan,
    BehaviorAddr<Worker>: EndpointAddress,
    StableProxy<Worker, Plan>: Behavior<Protocol = Worker::Protocol>,
{ /* private fields */ }

A fixed supervisor whose complete initial roster has been prepared.

Trait Implementations

impl<Role, Worker, Plan, Source, DiagnosticRoute, LifecycleRoute> Behavior for FixedSupervisor<Role, Worker, Plan, Source, DiagnosticRoute, LifecycleRoute>

where Role: Eq + Send + Sync, Worker: Behavior + Send, Plan: ActivationPlan, Source: WorkerSource<Role, Worker, Plan>, BehaviorAddr<Worker>: EndpointAddress, <BehaviorAddr<Worker> as Address>::Nonce: Send, StableProxy<Worker, Plan>: Behavior<Protocol = Worker::Protocol>, EstablishedActor<StableProxy<Worker, Plan>>: Clone + Send, DiagnosticRoute: DiagnosticRoute<FixedDiagnostic<Role, Worker, Plan, Source>> + Clone, LifecycleRoute: FixedLifecycleRoute<Role, Worker, Plan> + Clone, LifecycleRoute::Sends: SendsFor<FixedSupervisorEvent<Role, Worker, Plan, ActionItemResult<PrepareWorkers<Source, Role, Worker, Plan>>, WorkerPreparation<Source, Role, Worker, Plan>>>,

type Protocol = MessageProtocol<<<Worker as Behavior>::Protocol as Protocol>::Addr, FixedCommand<<<Worker as Behavior>::Protocol as Protocol>::Addr, Role, <Worker as Behavior>::Protocol>>

Stable public communication identity owned by this actor template.

type Event = FixedSupervisorEvent<Role, Worker, Plan, SettledItem<PrepareWorkers<Source, Role, Worker, Plan>, ItemSettlement<PrepareWorkers<Source, Role, Worker, Plan>, <PrepareWorkers<Source, Role, Worker, Plan> as ActionItem>::Accepted, <PrepareWorkers<Source, Role, Worker, Plan> as ActionItem>::Rejection, <PrepareWorkers<Source, Role, Worker, Plan> as ActionItem>::Prerequisite>>, WorkerPreparation<Source, Role, Worker, Plan>>

type Sends = FixedSupervisorRequests<InterpreterRequests<ObserveChild<<Worker as Behavior>::Protocol, ChildHead>>, SourceActions<PrepareWorkers<Source, Role, Worker, Plan>>, SourceActions<ProxyOperation<Here, Worker, Plan>>, SourceActions<ScheduleAfter>, <LifecycleRoute as FixedLifecycleRoute<Role, Worker, Plan>>::Sends, <ReplyRoute<MessageProtocol<<<Worker as Behavior>::Protocol as Protocol>::Addr, FixedSnapshot<<Worker as Behavior>::Protocol>>> as DeliveryRoute>::Sends, <ReplyRoute<MessageProtocol<<<Worker as Behavior>::Protocol as Protocol>::Addr, CapabilityResult<Role, <Worker as Behavior>::Protocol>>> as DeliveryRoute>::Sends, InterpreterRequests<DiagnosticAction<DiagnosticRoute, FixedDiagnostic<Role, Worker, Plan, Source>>>>

type Ph = Never

type Error = FixedSupervisorError<Role, Worker, Plan, SettledItem<PrepareWorkers<Source, Role, Worker, Plan>, ItemSettlement<PrepareWorkers<Source, Role, Worker, Plan>, <PrepareWorkers<Source, Role, Worker, Plan> as ActionItem>::Accepted, <PrepareWorkers<Source, Role, Worker, Plan> as ActionItem>::Rejection, <PrepareWorkers<Source, Role, Worker, Plan> as ActionItem>::Prerequisite>>, WorkerPreparation<Source, Role, Worker, Plan>>

type Birth = Births<StableProxy<Worker, Plan>>

fn init(&mut self, _: InitializationTurn) -> BehaviorActed<Self>

Produce initialization actions before the first event is accepted.

fn transition( &mut self, _: ActiveTurn, input: Self::Event, ) -> BehaviorActed<Self>

Fold exactly one event into explicit actions and the next behavior.

fn layer<L>(self, layer: L) -> <L as BehaviorLayer<Self>>::Output

where Self: Sized, L: BehaviorLayer<Self>,

Apply one statically dispatched construction layer.

impl<Role, Worker, Plan, Source, DiagnosticRoute, LifecycleRoute> BehaviorBase for FixedSupervisor<Role, Worker, Plan, Source, DiagnosticRoute, LifecycleRoute>

where Role: Send + Sync, Worker: Behavior + Send, Plan: ActivationPlan, Source: WorkerSource<Role, Worker, Plan>, BehaviorAddr<Worker>: EndpointAddress, <BehaviorAddr<Worker> as Address>::Nonce: Send, StableProxy<Worker, Plan>: Behavior<Protocol = Worker::Protocol>,

type Base = FixedSupervisor<Role, Worker, Plan, Source, DiagnosticRoute, LifecycleRoute>

fn base(&self) -> &Self::Base