Struct WorkQueueSends 

pub struct WorkQueueSends<Assignments, OutcomeSends> {
    pub assignments: Assignments,
    pub outcomes: OutcomeSends,
}

Named effect lanes emitted by WorkQueue.

Fields

assignments: Assignments

Work assigned to workers.

outcomes: OutcomeSends

Submission admission and dispatch facts.

Trait Implementations

impl<Assignments, OutcomeSends> ClassifySettlement for WorkQueueSends<Assignments, OutcomeSends>

where Assignments: ClassifySettlement, OutcomeSends: ClassifySettlement,

fn settlement_status(&self) -> SettlementStatus

Inspect every member without consuming or rewriting the settlement.

impl<Assignments, OutcomeSends, __BombayInterpreter, __BombayRootEvent, __BombayPath> InterpretSends<__BombayInterpreter, __BombayRootEvent, __BombayPath> for WorkQueueSends<Assignments, OutcomeSends>

where __BombayInterpreter: Send, WorkQueueSends<Assignments, OutcomeSends>: Send, Assignments: InterpretSends<__BombayInterpreter, __BombayRootEvent, __BombayPath>, OutcomeSends: InterpretSends<__BombayInterpreter, __BombayRootEvent, __BombayPath>, <WorkQueueSends<Assignments, OutcomeSends> as SendSettlements>::InterpretationCustody: Send,

fn interpret( progress: &mut Option<InterpretationProgress<Self, Self::InterpretationCustody, Self::Settlements>>, interpreter: &mut __BombayInterpreter, ) -> impl Future<Output = ()> + Send

impl<Assignments, OutcomeSends> LogicalDeliveryProtocols for WorkQueueSends<Assignments, OutcomeSends>

where Assignments: LogicalDeliveryProtocols, OutcomeSends: LogicalDeliveryProtocols,

type Protocols = <<NoBirthProtocols as BirthProtocolProduct>::Append<<Assignments as LogicalDeliveryProtocols>::Protocols> as BirthProtocolProduct>::Append<<OutcomeSends as LogicalDeliveryProtocols>::Protocols>

Ordered, duplicate-preserving logical protocol occurrences.

impl<Assignments, OutcomeSends> SendEffects for WorkQueueSends<Assignments, OutcomeSends>

where Assignments: SendEffects, OutcomeSends: SendEffects,

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<Assignments, OutcomeSends> SendSettlements for WorkQueueSends<Assignments, OutcomeSends>

where Assignments: SendSettlements, OutcomeSends: SendSettlements,

type Settlements = WorkQueueSends<<Assignments as SendSettlements>::Settlements, <OutcomeSends as SendSettlements>::Settlements>

type SourceCustody = (Option<SourceProgress<<Assignments as SendSettlements>::Settlements, <Assignments as SendSettlements>::SourceCustody>>, Option<SourceProgress<(<OutcomeSends as SendSettlements>::Settlements, NoSends), (Option<SourceProgress<<OutcomeSends as SendSettlements>::Settlements, <OutcomeSends as SendSettlements>::SourceCustody>>, Option<SourceProgress<NoSends, NoSends>>)>>)

type InterpretationCustody = (Option<InterpretationProgress<Assignments, <Assignments as SendSettlements>::InterpretationCustody, <Assignments as SendSettlements>::Settlements>>, Option<InterpretationProgress<OutcomeSends, <OutcomeSends as SendSettlements>::InterpretationCustody, <OutcomeSends as SendSettlements>::Settlements>>)

fn prepare_interpretation( progress: &mut Option<InterpretationProgress<Self, Self::InterpretationCustody, Self::Settlements>>, )

fn finish_interpretation( progress: &mut Option<InterpretationProgress<Self, Self::InterpretationCustody, Self::Settlements>>, )

fn unattempted( progress: &mut Option<InterpretationProgress<Self, Self::InterpretationCustody, Self::Settlements>>, )

impl<Assignments, OutcomeSends, __BombaySettlementHost, __BombaySettlementEvent> SourceSettlementCustody<__BombaySettlementHost, __BombaySettlementEvent> for WorkQueueSends<Assignments, OutcomeSends>

where __BombaySettlementHost: Send, Assignments: SourceSettlementCustody<__BombaySettlementHost, __BombaySettlementEvent> + Send, OutcomeSends: SourceSettlementCustody<__BombaySettlementHost, __BombaySettlementEvent> + Send,

type Custody = (Option<SourceProgress<Assignments, <Assignments as SourceSettlementCustody<__BombaySettlementHost, __BombaySettlementEvent>>::Custody>>, Option<SourceProgress<(OutcomeSends, NoSends), (Option<SourceProgress<OutcomeSends, <OutcomeSends as SourceSettlementCustody<__BombaySettlementHost, __BombaySettlementEvent>>::Custody>>, Option<SourceProgress<NoSends, NoSends>>)>>)

fn prepare_source(progress: &mut Option<SourceProgress<Self, Self::Custody>>)

fn offer_next_to_source( custody: &mut Self::Custody, host: &mut __BombaySettlementHost, ) -> impl Future<Output = ()> + Send

fn finish_source(progress: &mut Option<SourceProgress<Self, Self::Custody>>)

impl<Assignments, OutcomeSends, __BombayEvent> SendsFor<__BombayEvent> for WorkQueueSends<Assignments, OutcomeSends>

where Assignments: SendsFor<__BombayEvent>, OutcomeSends: SendsFor<__BombayEvent>,