Struct StableProxy 

pub struct StableProxy<W, P>
where
    W: Behavior,
    P: ActivationPlan,
    BehaviorAddr<W>: EndpointAddress,
{ /* private fields */ }

One stable service identity backed by zero or one exact current worker.

Implementations

impl<W> StableProxy<W, ImmediateActivation>

where W: Behavior, BehaviorAddr<W>: EndpointAddress,

pub const fn immediate() -> Self

Construct an empty proxy for workers needing no activation work.

impl<W, P> StableProxy<W, P>

where W: Behavior, P: ActivationPlan, BehaviorAddr<W>: EndpointAddress,

pub const fn activated() -> Self

Construct an empty proxy whose worker start supplies a concrete plan.

pub const fn phase(&self) -> ProxyPhase

Project the current lifecycle phase without exposing worker authority.

Trait Implementations

impl<W, P> Behavior for StableProxy<W, P>

where W: Behavior, P: ActivationPlan, BehaviorAddr<W>: EndpointAddress, <BehaviorAddr<W> as Address>::Nonce: Copy + Eq + Send, StopOnShutdown<W>: Behavior<Protocol = W::Protocol, Error = W::Error, Ph = W::Ph, Birth = W::Birth>, <StopOnShutdown<W> as Behavior>::Event: InjectEvent<ShutdownRequested, Here>, <StopOnShutdown<W> as Behavior>::Sends: SendSettlements, <W::Birth as BirthMode>::Child: ChildCreationProduct<BehaviorAddr<W>, ChildHead>, EstablishedRecipient<W::Protocol>: Send,

type Protocol = <W as Behavior>::Protocol

Stable public communication identity owned by this actor template.

type Event = ProxyEvent<W, P>

type Sends = ProxyEffects<InterpreterRequests<ObserveChild<<W as Behavior>::Protocol, ChildHead>>, InterpreterRequests<InitializeWorker<W, P>>, InterpreterRequests<BeginActivation<W, P>>, InterpreterRequests<ShutdownEstablished<StopOnShutdown<W>, Here>>, Vec<EstablishedDelivery<<W as Behavior>::Protocol>>, InterpreterRequests<ReportToParent<ProxyOutcome<W, P>>>, InterpreterRequests<ReportToParent<ProxyDiagnostic<W, P>>>>

type Ph = Never

type Error = Never

type Birth = Births<StopOnShutdown<W>>

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

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

fn init( &mut self, _turn: InitializationTurn, ) -> Result<Actions<<Self::Protocol as Protocol>::Addr, Self::Ph, Self::Sends, Self::Birth>, Self::Error>

where Self: Sized,

Produce initialization actions before the first event is accepted.

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

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

Apply one statically dispatched construction layer.

impl<W, P> BehaviorBase for StableProxy<W, P>

where W: Behavior, P: ActivationPlan, BehaviorAddr<W>: EndpointAddress,

type Base = StableProxy<W, P>

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