Struct ReplyDeliveries 

pub struct ReplyDeliveries<Logical, Established> { /* private fields */ }

Ordered customer-delivery lane preserving each route alternative.

Implementations

impl<Logical, Established> ReplyDeliveries<Logical, Established>

pub fn new(deliveries: Vec<ReplyDelivery<Logical, Established>>) -> Self

Construct one ordered customer-delivery lane.

pub fn as_slice(&self) -> &[ReplyDelivery<Logical, Established>]

Inspect the complete delivery order without exposing endpoint internals.

pub fn into_deliveries(self) -> Vec<ReplyDelivery<Logical, Established>>

Consume the lane into its complete ordered alternatives.

Trait Implementations

impl<Logical, Established> ClassifySettlement for ReplyDeliveries<Logical, Established>

where Logical: ClassifySettlement, Established: ClassifySettlement,

fn settlement_status(&self) -> SettlementStatus

Inspect every member without consuming or rewriting the settlement.

impl<Logical: Clone, Established: Clone> Clone for ReplyDeliveries<Logical, Established>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<Logical, Established> Debug for ReplyDeliveries<Logical, Established>

where ReplyDelivery<Logical, Established>: Debug,

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<Interpreter, RootEvent, Path, P> InterpretSends<Interpreter, RootEvent, Path> for ReplyDeliveries<Delivery<P>, EstablishedDelivery<P>>

where Interpreter: InterpretItem<Delivery<P>, RootEvent, Path> + InterpretItem<EstablishedDelivery<P>, RootEvent, Path> + Send, P: Protocol, P::Addr: EndpointAddress + Send, P::Msg: Send, <P::Addr as RecipientAddress>::Established<P>: Send,

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

impl<P> LogicalDeliveryProtocols for ReplyDeliveries<Delivery<P>, EstablishedDelivery<P>>

where P: Protocol, P::Addr: EndpointAddress,

type Protocols = BirthProtocol<P, NoBirthProtocols>

Ordered, duplicate-preserving logical protocol occurrences.

impl<Logical, Established> PartialEq for ReplyDeliveries<Logical, Established>

where ReplyDelivery<Logical, Established>: PartialEq,

fn eq(&self, other: &Self) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<Logical, Established> SendEffects for ReplyDeliveries<Logical, Established>

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<Logical, Established> SendInput<ReplyDelivery<Logical, Established>, Own> for ReplyDeliveries<Logical, Established>

fn emit(&mut self, input: ReplyDelivery<Logical, Established>)

impl<P> SendSettlements for ReplyDeliveries<Delivery<P>, EstablishedDelivery<P>>

where P: Protocol, P::Addr: EndpointAddress, Delivery<P>: ActionItem, EstablishedDelivery<P>: ActionItem,

type Settlements = ReplyDeliveries<SettledItem<Delivery<P>, ItemSettlement<Delivery<P>, <Delivery<P> as ActionItem>::Accepted, <Delivery<P> as ActionItem>::Rejection, <Delivery<P> as ActionItem>::Prerequisite>>, SettledItem<EstablishedDelivery<P>, ItemSettlement<EstablishedDelivery<P>, <EstablishedDelivery<P> as ActionItem>::Accepted, <EstablishedDelivery<P> as ActionItem>::Rejection, <EstablishedDelivery<P> as ActionItem>::Prerequisite>>>

type SourceCustody = <ReplyDeliveries<Delivery<P>, EstablishedDelivery<P>> as SendSettlements>::Settlements

type InterpretationCustody = Vec<ReplyDelivery<(Option<Delivery<P>>, Option<ItemSettlement<Delivery<P>, <Delivery<P> as ActionItem>::Accepted, <Delivery<P> as ActionItem>::Rejection, <Delivery<P> as ActionItem>::Prerequisite>>), (Option<EstablishedDelivery<P>>, Option<ItemSettlement<EstablishedDelivery<P>, <EstablishedDelivery<P> as ActionItem>::Accepted, <EstablishedDelivery<P> as ActionItem>::Rejection, <EstablishedDelivery<P> as ActionItem>::Prerequisite>>)>>

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<Host, RootEvent, P> SourceSettlementCustody<Host, RootEvent> for ReplyDeliveries<ActionItemResult<Delivery<P>>, ActionItemResult<EstablishedDelivery<P>>>

where P: Protocol, P::Addr: EndpointAddress, Delivery<P>: ActionItem, EstablishedDelivery<P>: ActionItem,

type Custody = ReplyDeliveries<SettledItem<Delivery<P>, ItemSettlement<Delivery<P>, <Delivery<P> as ActionItem>::Accepted, <Delivery<P> as ActionItem>::Rejection, <Delivery<P> as ActionItem>::Prerequisite>>, SettledItem<EstablishedDelivery<P>, ItemSettlement<EstablishedDelivery<P>, <EstablishedDelivery<P> as ActionItem>::Accepted, <EstablishedDelivery<P> as ActionItem>::Rejection, <EstablishedDelivery<P> as ActionItem>::Prerequisite>>>

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

fn offer_next_to_source( _: &mut Self::Custody, _: &mut Host, ) -> impl Future<Output = ()> + Send

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

impl<Logical, Established> Eq for ReplyDeliveries<Logical, Established>

where ReplyDelivery<Logical, Established>: Eq,

impl<Event, Logical, Established> SendsFor<Event> for ReplyDeliveries<Logical, Established>