Struct Proxy 

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

The stable actor. Every replacement is an ordinary fresh birth beneath it.

Each emitted worker birth is paired with an ObserveChild request. A matching [ChildStopped] leaves the proxy alive and emits a ReportWorkerStopped carrying the outcome unchanged. Stale child-stop observations are inert.

Implementations

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

pub fn new(worker: C) -> Self

Trait Implementations

impl<C> Behavior for Proxy<C>

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

type Addr = <C as Behavior>::Addr

type Msg = ProxyCommand<C>

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

type Sends = SendProduct<Vec<Delivery<<C as Behavior>::Addr, <C as Behavior>::Msg>>, SendProduct<ServiceSends<ObserveChild<<C as Behavior>::Addr>>, ServiceSends<ReportWorkerStopped<<C as Behavior>::Addr>>>>

type Ph = Never

type Error = Never

type Birth = Births<C>

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

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