Struct ProxySends 

pub struct ProxySends<A: Address, M> {
    pub deliveries: Vec<Delivery<A, M>>,
    pub child_observations: ServiceSends<ObserveChild<A::Nonce>>,
    pub creation_observations: ServiceSends<ObserveCreation<A::Nonce>>,
    pub stopped_reports: ServiceSends<ReportWorkerStopped<A>>,
    pub creation_reports: ServiceSends<ReportWorkerCreationResolved<A::Nonce>>,
}

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

Fields

deliveries: Vec<Delivery<A, M>>

child_observations: ServiceSends<ObserveChild<A::Nonce>>

creation_observations: ServiceSends<ObserveCreation<A::Nonce>>

stopped_reports: ServiceSends<ReportWorkerStopped<A>>

creation_reports: ServiceSends<ReportWorkerCreationResolved<A::Nonce>>

Trait Implementations

impl<A: Address, M> SendAlgebra for ProxySends<A, M>

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<A: Address, M> SendInput<Delivery<A, M>, Own> for ProxySends<A, M>

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

impl<A: Address, M> SendInput<ObserveChild<<A as Address>::Nonce>, Own> for ProxySends<A, M>

fn emit(&mut self, input: ObserveChild<A::Nonce>)

impl<A: Address, M> SendInput<ObserveCreation<<A as Address>::Nonce>, Own> for ProxySends<A, M>

fn emit(&mut self, input: ObserveCreation<A::Nonce>)

impl<A: Address, M> SendInput<ReportWorkerCreationResolved<<A as Address>::Nonce>, Own> for ProxySends<A, M>

fn emit(&mut self, input: ReportWorkerCreationResolved<A::Nonce>)

impl<A: Address, M> SendInput<ReportWorkerStopped<A>, Own> for ProxySends<A, M>

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