Struct BreakerSends 

pub struct BreakerSends<ReplySends, Schedules> {
    pub replies: ReplySends,
    pub schedules: Schedules,
}

Named output lanes for circuit facts and reset scheduling.

Fields

replies: ReplySends

Admission and completion facts.

schedules: Schedules

Relative reset requests interpreted by Bombay Timers.

Trait Implementations

impl<ReplySends, Schedules> ClassifySettlement for BreakerSends<ReplySends, Schedules>

where ReplySends: ClassifySettlement, Schedules: ClassifySettlement,

fn settlement_status(&self) -> SettlementStatus

Inspect every member without consuming or rewriting the settlement.

impl<ReplySends, Schedules, __BombayInterpreter, __BombayRootEvent, __BombayPath> InterpretSends<__BombayInterpreter, __BombayRootEvent, __BombayPath> for BreakerSends<ReplySends, Schedules>

where __BombayInterpreter: Send, BreakerSends<ReplySends, Schedules>: Send, ReplySends: InterpretSends<__BombayInterpreter, __BombayRootEvent, __BombayPath>, Schedules: InterpretSends<__BombayInterpreter, __BombayRootEvent, __BombayPath>, <BreakerSends<ReplySends, Schedules> as SendSettlements>::InterpretationCustody: Send,

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

impl<ReplySends, Schedules> LogicalDeliveryProtocols for BreakerSends<ReplySends, Schedules>

where ReplySends: LogicalDeliveryProtocols, Schedules: LogicalDeliveryProtocols,

type Protocols = <<NoBirthProtocols as BirthProtocolProduct>::Append<<ReplySends as LogicalDeliveryProtocols>::Protocols> as BirthProtocolProduct>::Append<<Schedules as LogicalDeliveryProtocols>::Protocols>

Ordered, duplicate-preserving logical protocol occurrences.

impl<ReplySends, Schedules> SendEffects for BreakerSends<ReplySends, Schedules>

where ReplySends: SendEffects, Schedules: 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<ReplySends, Schedules> SendSettlements for BreakerSends<ReplySends, Schedules>

where ReplySends: SendSettlements, Schedules: SendSettlements,

type Settlements = BreakerSends<<ReplySends as SendSettlements>::Settlements, <Schedules as SendSettlements>::Settlements>

type SourceCustody = (Option<SourceProgress<<ReplySends as SendSettlements>::Settlements, <ReplySends as SendSettlements>::SourceCustody>>, Option<SourceProgress<(<Schedules as SendSettlements>::Settlements, NoSends), (Option<SourceProgress<<Schedules as SendSettlements>::Settlements, <Schedules as SendSettlements>::SourceCustody>>, Option<SourceProgress<NoSends, NoSends>>)>>)

type InterpretationCustody = (Option<InterpretationProgress<ReplySends, <ReplySends as SendSettlements>::InterpretationCustody, <ReplySends as SendSettlements>::Settlements>>, Option<InterpretationProgress<Schedules, <Schedules as SendSettlements>::InterpretationCustody, <Schedules 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<ReplySends, Schedules, __BombaySettlementHost, __BombaySettlementEvent> SourceSettlementCustody<__BombaySettlementHost, __BombaySettlementEvent> for BreakerSends<ReplySends, Schedules>

where __BombaySettlementHost: Send, ReplySends: SourceSettlementCustody<__BombaySettlementHost, __BombaySettlementEvent> + Send, Schedules: SourceSettlementCustody<__BombaySettlementHost, __BombaySettlementEvent> + Send,

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

where ReplySends: SendsFor<__BombayEvent>, Schedules: SendsFor<__BombayEvent>,