Struct TerminalPropagationSends 

pub struct TerminalPropagationSends<Observations, Reports> {
    pub observations: Observations,
    pub reports: Reports,
}

Named effects owned by PropagateTermination.

Fields

observations: Observations

reports: Reports

Trait Implementations

impl<Observations, Reports> ClassifySettlement for TerminalPropagationSends<Observations, Reports>

where Observations: ClassifySettlement, Reports: ClassifySettlement,

fn settlement_status(&self) -> SettlementStatus

Inspect every member without consuming or rewriting the settlement.

impl<Observations, Reports, __BombayInterpreter, __BombayRootEvent, __BombayPath> InterpretSends<__BombayInterpreter, __BombayRootEvent, __BombayPath> for TerminalPropagationSends<Observations, Reports>

where __BombayInterpreter: Send, TerminalPropagationSends<Observations, Reports>: Send, Observations: InterpretSends<__BombayInterpreter, __BombayRootEvent, __BombayPath>, Reports: InterpretSends<__BombayInterpreter, __BombayRootEvent, __BombayPath>, <TerminalPropagationSends<Observations, Reports> as SendSettlements>::InterpretationCustody: Send,

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

impl<Observations, Reports> LogicalDeliveryProtocols for TerminalPropagationSends<Observations, Reports>

where Observations: LogicalDeliveryProtocols, Reports: LogicalDeliveryProtocols,

type Protocols = <<NoBirthProtocols as BirthProtocolProduct>::Append<<Observations as LogicalDeliveryProtocols>::Protocols> as BirthProtocolProduct>::Append<<Reports as LogicalDeliveryProtocols>::Protocols>

Ordered, duplicate-preserving logical protocol occurrences.

impl<Observations, Reports> SendEffects for TerminalPropagationSends<Observations, Reports>

where Observations: SendEffects, Reports: 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<Observations, Reports> SendSettlements for TerminalPropagationSends<Observations, Reports>

where Observations: SendSettlements, Reports: SendSettlements,

type Settlements = TerminalPropagationSends<<Observations as SendSettlements>::Settlements, <Reports as SendSettlements>::Settlements>

type SourceCustody = (Option<SourceProgress<<Observations as SendSettlements>::Settlements, <Observations as SendSettlements>::SourceCustody>>, Option<SourceProgress<(<Reports as SendSettlements>::Settlements, NoSends), (Option<SourceProgress<<Reports as SendSettlements>::Settlements, <Reports as SendSettlements>::SourceCustody>>, Option<SourceProgress<NoSends, NoSends>>)>>)

type InterpretationCustody = (Option<InterpretationProgress<Observations, <Observations as SendSettlements>::InterpretationCustody, <Observations as SendSettlements>::Settlements>>, Option<InterpretationProgress<Reports, <Reports as SendSettlements>::InterpretationCustody, <Reports 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<Observations, Reports, __BombaySettlementHost, __BombaySettlementEvent> SourceSettlementCustody<__BombaySettlementHost, __BombaySettlementEvent> for TerminalPropagationSends<Observations, Reports>

where __BombaySettlementHost: Send, Observations: SourceSettlementCustody<__BombaySettlementHost, __BombaySettlementEvent> + Send, Reports: SourceSettlementCustody<__BombaySettlementHost, __BombaySettlementEvent> + Send,

type Custody = (Option<SourceProgress<Observations, <Observations as SourceSettlementCustody<__BombaySettlementHost, __BombaySettlementEvent>>::Custody>>, Option<SourceProgress<(Reports, NoSends), (Option<SourceProgress<Reports, <Reports 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<Observations, Reports, __BombayEvent> SendsFor<__BombayEvent> for TerminalPropagationSends<Observations, Reports>

where Observations: SendsFor<__BombayEvent>, Reports: SendsFor<__BombayEvent>,