Struct Proxy 

pub struct Proxy<C>
where
    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> Proxy<C>

where C: Behavior<Ph = Never>,

pub fn new(worker: C) -> Proxy<C>

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

Trait Implementations

impl<C> Behavior for Proxy<C>

where C: Behavior<Ph = Never>, <<C as Behavior>::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 as Behavior>::Addr, Never, <Proxy<C> as Behavior>::Sends, Births<C>>, Never>

Produce initialization actions before the first event is accepted.

fn transition( &mut self, event: <Proxy<C> as Behavior>::Event, ) -> Result<Actions<<C as Behavior>::Addr, Never, <Proxy<C> as Behavior>::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, ) -> Result<Actions<Self::Addr, Self::Ph, Self::Sends, Self::Birth>, Self::Error>

where Self: Sized,

Fold one user communication through the composed protocol.

fn on<Input>( &mut self, input: Input, ) -> Result<Actions<Self::Addr, Self::Ph, Self::Sends, Self::Birth>, Self::Error>

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

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