Struct DynamicSupervisor 

pub struct DynamicSupervisor<Key, Worker, Plan, LifecycleRoute, DiagnosticRoute>
where
    Worker: Behavior,
    Plan: ActivationPlan,
    BehaviorAddr<Worker>: EndpointAddress,
    StableProxy<Worker, Plan>: Behavior<Protocol = Worker::Protocol>,
{ /* private fields */ }

One bounded keyed supervisor with a stable proxy per retained service.

Trait Implementations

impl<Key, Worker, Plan, LifecycleRoute, DiagnosticRouteType> Behavior for DynamicSupervisor<Key, Worker, Plan, LifecycleRoute, DiagnosticRouteType>

where Key: Clone + Ord + Send + Sync, Worker: Behavior + Send, Plan: ActivationPlan, BehaviorAddr<Worker>: EndpointAddress, <BehaviorAddr<Worker> as Address>::Nonce: Send, StableProxy<Worker, Plan>: Behavior<Protocol = Worker::Protocol>, EstablishedActor<StableProxy<Worker, Plan>>: Clone + Send, LifecycleRoute: DeliveryRoute<Protocol = MessageProtocol<BehaviorAddr<Worker>, DynamicLifecycle<Key, Worker, Plan>>> + Clone, LifecycleRoute::Sends: SendsFor<DynamicSupervisorEvent<Key, Worker, Plan>>, DiagnosticRouteType: DiagnosticRoute<DynamicDiagnostic<Key, Worker, Plan>> + Clone,

type Protocol = MessageProtocol<<<Worker as Behavior>::Protocol as Protocol>::Addr, DynamicCommand<Key, Worker, Plan>>

Stable public communication identity owned by this actor template.

type Event = DynamicSupervisorEvent<Key, Worker, Plan>

type Sends = DynamicSupervisorRequests<InterpreterRequests<ObserveChild<<Worker as Behavior>::Protocol, ChildHead>>, SourceActions<ProxyOperation<Here, Worker, Plan>>, SourceActions<ScheduleAfter>, <ReplyRoute<MessageProtocol<<<Worker as Behavior>::Protocol as Protocol>::Addr, Result<WorkerChangeReceipt<Key>, WorkerChangeRejection<Key, Worker, Plan, StartRejection>>>> as DeliveryRoute>::Sends, <ReplyRoute<MessageProtocol<<<Worker as Behavior>::Protocol as Protocol>::Addr, Result<WorkerChangeReceipt<Key>, WorkerChangeRejection<Key, Worker, Plan, ReplaceRejection>>>> as DeliveryRoute>::Sends, <ReplyRoute<MessageProtocol<<<Worker as Behavior>::Protocol as Protocol>::Addr, Result<Key, StopRejection<Key>>>> as DeliveryRoute>::Sends, <ReplyRoute<MessageProtocol<<<Worker as Behavior>::Protocol as Protocol>::Addr, QueryReply<Key, <Worker as Behavior>::Protocol>>> as DeliveryRoute>::Sends, <ReplyRoute<MessageProtocol<<<Worker as Behavior>::Protocol as Protocol>::Addr, CancellationReceipt<Key, Worker, Plan>>> as DeliveryRoute>::Sends, <LifecycleRoute as DeliveryRoute>::Sends, InterpreterRequests<DiagnosticAction<DiagnosticRouteType, DynamicDiagnostic<Key, Worker, Plan>>>>

type Ph = Never

type Error = DynamicSupervisorEvent<Key, 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<Key, Worker, Plan, LifecycleRoute, DiagnosticRouteType> BehaviorBase for DynamicSupervisor<Key, Worker, Plan, LifecycleRoute, DiagnosticRouteType>

where Worker: Behavior, Plan: ActivationPlan, BehaviorAddr<Worker>: EndpointAddress, StableProxy<Worker, Plan>: Behavior<Protocol = Worker::Protocol>,

type Base = DynamicSupervisor<Key, Worker, Plan, LifecycleRoute, DiagnosticRouteType>

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