Struct PoolBehaviorSends 

pub struct PoolBehaviorSends<A, D, J, R, C>
where
    A: Address,
    A::Nonce: From<u64>,
    D: Behavior<Addr = A, Msg = PoolResponse<J, R, A>>,
    C: Behavior<Addr = A, Ph = Never>,
{
    pub responses: Vec<Delivery<D>>,
    pub assignments: Vec<Delivery<Proxy<C>>>,
}

Named pool-owned delivery lanes.

Fields

responses: Vec<Delivery<D>>

Admission and terminal responses addressed to submitters.

assignments: Vec<Delivery<Proxy<C>>>

Assignments addressed to the selected stable worker proxies.

Trait Implementations

impl<A, D, J, R, C> SendAlgebra for PoolBehaviorSends<A, D, J, R, C>

where A: Address, A::Nonce: From<u64>, D: Behavior<Addr = A, Msg = PoolResponse<J, R, A>>, C: Behavior<Addr = A, Ph = Never>,

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, D, J, R, C> SendInput<Delivery<D>, Own> for PoolBehaviorSends<A, D, J, R, C>

where A: Address, A::Nonce: From<u64>, D: Behavior<Addr = A, Msg = PoolResponse<J, R, A>>, C: Behavior<Addr = A, Ph = Never>,

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

impl<A, D, J, R, C> SendInput<Delivery<Proxy<C>>, Own> for PoolBehaviorSends<A, D, J, R, C>

where A: Address, A::Nonce: From<u64>, D: Behavior<Addr = A, Msg = PoolResponse<J, R, A>>, C: Behavior<Addr = A, Ph = Never>,

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