Struct Proxy 

pub struct Proxy<C: Behavior<Ph = Never>> { /* private fields */ }

A stable actor that serializes fresh worker-incarnation installation.

A worker is routable only in Running. Deadline most one creation can be Installing; stale or provenance-mismatched results are inert. Rejection leaves last_installed unchanged, so a later attempt still names the last incarnation that actually existed.

Implementations

impl<C: Behavior<Ph = Never>> Proxy<C>

pub fn new(worker: C) -> Self

pub const fn phase(&self) -> IncarnationPhase<<C::Addr as Address>::Nonce>

Trait Implementations

impl<C> Behavior for Proxy<C>

where C: Behavior<Ph = Never>, <C::Addr as Address>::Nonce: From<u64>,

type Addr = <C as Behavior>::Addr

type Msg = ProxyCommand<C>

type Event = ProxyEvent<User<<C as Behavior>::Addr, ProxyCommand<C>>>

type Sends = ProxySends<<C as Behavior>::Addr, <C as Behavior>::Msg>

type Ph = Never

type Error = Never

type Birth = Births<C>

fn init( &mut self, ) -> Result<Actions<C::Addr, Never, Self::Sends, Births<C>>, Never>

Produce initialization actions before the first event is accepted.

fn transition( &mut self, event: Self::Event, ) -> Result<Actions<C::Addr, Never, Self::Sends, Births<C>>, Never>

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

fn receive( &mut self, from: Self::Addr, message: Self::Msg, ) -> BehaviorActed<Self>

where Self: Sized,

Fold one user communication through the composed protocol.

fn on<Input>(&mut self, input: Input) -> BehaviorActed<Self>

where Self: Sized, Self::Event: EventInput<Input>,

Inject one supported semantic input and fold it through this behavior.