Struct ProxySends 

pub struct ProxySends<C: Behavior> {
    pub deliveries: Vec<Delivery<C>>,
    pub child_observations: ServiceSends<ObserveChild<<C::Addr as Address>::Nonce>>,
    pub creation_observations: ServiceSends<ObserveCreation<<C::Addr as Address>::Nonce>>,
    pub stopped_reports: ServiceSends<ReportWorkerStopped<C::Addr>>,
    pub creation_reports: ServiceSends<ReportWorkerCreationResolved<<C::Addr as Address>::Nonce>>,
}

The concrete, statically dispatched effect lanes emitted by a Proxy.

Fields

deliveries: Vec<Delivery<C>>

child_observations: ServiceSends<ObserveChild<<C::Addr as Address>::Nonce>>

creation_observations: ServiceSends<ObserveCreation<<C::Addr as Address>::Nonce>>

stopped_reports: ServiceSends<ReportWorkerStopped<C::Addr>>

creation_reports: ServiceSends<ReportWorkerCreationResolved<<C::Addr as Address>::Nonce>>

Trait Implementations

impl<C: Behavior> SendAlgebra for ProxySends<C>

fn empty() -> Self

fn append(&mut self, other: Self)

fn combine(self, other: Self) -> Self

fn send<Input, Path>(&mut self, input: Input)

where Self: SendInput<Input, Path>,

Append one request to its statically selected semantic lane.

fn sending<Input, Path>(input: Input) -> Self

where Self: SendInput<Input, Path>,

Build a send product containing one request in its selected lane.

impl<C: Behavior> SendInput<Delivery<C>, Own> for ProxySends<C>

fn emit(&mut self, input: Delivery<C>)

impl<C: Behavior> SendInput<ObserveChild<<<C as Behavior>::Addr as Address>::Nonce>, Own> for ProxySends<C>

fn emit(&mut self, input: ObserveChild<<C::Addr as Address>::Nonce>)

impl<C: Behavior> SendInput<ObserveCreation<<<C as Behavior>::Addr as Address>::Nonce>, Own> for ProxySends<C>

fn emit(&mut self, input: ObserveCreation<<C::Addr as Address>::Nonce>)

impl<C: Behavior> SendInput<ReportWorkerCreationResolved<<<C as Behavior>::Addr as Address>::Nonce>, Own> for ProxySends<C>

fn emit( &mut self, input: ReportWorkerCreationResolved<<C::Addr as Address>::Nonce>, )

impl<C: Behavior> SendInput<ReportWorkerStopped<<C as Behavior>::Addr>, Own> for ProxySends<C>

fn emit(&mut self, input: ReportWorkerStopped<C::Addr>)