Struct LeaseSends 

pub struct LeaseSends<OutcomeSends, Schedules> {
    pub outcomes: OutcomeSends,
    pub schedules: Schedules,
}

Named effect lanes emitted by Lease.

Fields

outcomes: OutcomeSends

Lease facts.

schedules: Schedules

Relative expiry requests.

Trait Implementations

impl<OutcomeSends, Schedules> ClassifySettlement for LeaseSends<OutcomeSends, Schedules>

where OutcomeSends: ClassifySettlement, Schedules: ClassifySettlement,

fn settlement_status(&self) -> SettlementStatus

Inspect every member without consuming or rewriting the settlement.

impl<OutcomeSends, Schedules, __BombayInterpreter, __BombayRootEvent, __BombayPath> InterpretSends<__BombayInterpreter, __BombayRootEvent, __BombayPath> for LeaseSends<OutcomeSends, Schedules>

where __BombayInterpreter: Send, LeaseSends<OutcomeSends, Schedules>: Send, OutcomeSends: InterpretSends<__BombayInterpreter, __BombayRootEvent, __BombayPath>, Schedules: InterpretSends<__BombayInterpreter, __BombayRootEvent, __BombayPath>, <LeaseSends<OutcomeSends, Schedules> as SendSettlements>::InterpretationCustody: Send,

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

impl<OutcomeSends, Schedules> LogicalDeliveryProtocols for LeaseSends<OutcomeSends, Schedules>

where OutcomeSends: LogicalDeliveryProtocols, Schedules: LogicalDeliveryProtocols,

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

Ordered, duplicate-preserving logical protocol occurrences.

impl<OutcomeSends, Schedules> SendEffects for LeaseSends<OutcomeSends, Schedules>

where OutcomeSends: 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<OutcomeSends, Schedules> SendSettlements for LeaseSends<OutcomeSends, Schedules>

where OutcomeSends: SendSettlements, Schedules: SendSettlements,

type Settlements = LeaseSends<<OutcomeSends as SendSettlements>::Settlements, <Schedules as SendSettlements>::Settlements>

type SourceCustody = (Option<SourceProgress<<OutcomeSends as SendSettlements>::Settlements, <OutcomeSends 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<OutcomeSends, <OutcomeSends as SendSettlements>::InterpretationCustody, <OutcomeSends 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<OutcomeSends, Schedules, __BombaySettlementHost, __BombaySettlementEvent> SourceSettlementCustody<__BombaySettlementHost, __BombaySettlementEvent> for LeaseSends<OutcomeSends, Schedules>

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

type Custody = (Option<SourceProgress<OutcomeSends, <OutcomeSends 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<OutcomeSends, Schedules, __BombayEvent> SendsFor<__BombayEvent> for LeaseSends<OutcomeSends, Schedules>

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