Struct SourceActions 

pub struct SourceActions<Item> { /* private fields */ }

Ordered actions whose normalized results return to their emitting actor.

This product is interpreter-facing machinery. Aggregate builders expose domain operations, not this structural lane.

Implementations

impl<Item> SourceActions<Item>

pub fn len(&self) -> usize

Number of requests retained in authored order.

pub fn is_empty(&self) -> bool

Report whether this ordered request lane contains no items.

pub fn into_items(self) -> Vec<Item>

Consume the lane into its requests in authored order.

Trait Implementations

impl<Interpreter, RootEvent, Path, Item> InterpretSends<Interpreter, RootEvent, Path> for SourceActions<Item>

where Interpreter: InterpretItem<Item, RootEvent, Path>, Item: SourceAction, Item::Custody: Send,

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

impl<Item> LogicalDeliveryProtocols for SourceActions<Item>

type Protocols = NoBirthProtocols

Ordered, duplicate-preserving logical protocol occurrences.

impl<Item> SendEffects for SourceActions<Item>

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<Item> SendInput<Item, Own> for SourceActions<Item>

fn emit(&mut self, input: Item)

impl<Item> SendSettlements for SourceActions<Item>

where Item: SourceAction,

type Settlements = SourceSettlements<Item>

type SourceCustody = (Option<SettledItem<Item, ItemSettlement<Item, <Item as ActionItem>::Accepted, <Item as ActionItem>::Rejection, <Item as ActionItem>::Prerequisite>>>, IntoIter<SettledItem<Item, ItemSettlement<Item, <Item as ActionItem>::Accepted, <Item as ActionItem>::Rejection, <Item as ActionItem>::Prerequisite>>>, Option<Result<(), SettledItem<Item, ItemSettlement<Item, <Item as ActionItem>::Accepted, <Item as ActionItem>::Rejection, <Item as ActionItem>::Prerequisite>>>>)

type InterpretationCustody = Vec<Option<InterpretationProgress<Item, <Item as ActionItem>::Custody, ItemSettlement<Item, <Item as ActionItem>::Accepted, <Item as ActionItem>::Rejection, <Item 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<Event, Item> SendsFor<Event> for SourceActions<Item>

where Item: SourceAction,