Struct Acknowledgements 

pub struct Acknowledgements<A: Address, K, P, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = AcknowledgementOutcome<K, P>>>> { /* private fields */ }

Typed multi-participant acknowledgement behavior.

Begin normalizes participant membership by first occurrence. An empty set completes immediately. Each declared participant can advance a pending lifecycle exactly once; the final acknowledgement atomically commits AcknowledgementState::Completed and reports completion. Cancellation is accepted only while pending. Completed and cancelled records are retained, making stale terminal input distinguishable from an unknown key. Every rejection is emitted as a concrete AcknowledgementError and leaves the state unchanged. Initialization is empty, the template creates no actors, and it does not terminate its host. Membership normalization, terminal retention, and acknowledgement ordering are Bombay policy. Delivery remains a runtime capability, and transitions have no panic path.

Implementations

impl<A, K, P, Route> Acknowledgements<A, K, P, Route>

where A: Address, K: Clone + Eq, P: Clone + Eq, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = AcknowledgementOutcome<K, P>>>,

pub const fn new() -> Self

Construct an empty acknowledgement table.

pub fn records(&self) -> &[AcknowledgementRecord<K, P>]

Borrow every pending or retained terminal lifecycle.

Trait Implementations

impl<A, K, P, Route> Behavior for Acknowledgements<A, K, P, Route>

where A: Address, K: Clone + Eq, P: Clone + Eq, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = AcknowledgementOutcome<K, P>>>, Route::Sends: SendsFor<User<A, AcknowledgementMessage<K, P, Route>>>,

type Protocol = Acknowledgements<A, K, P, Route>

Stable public communication identity owned by this actor template.

type Event = User<A, <<Acknowledgements<A, K, P, Route> as Behavior>::Protocol as Protocol>::Msg>

type Sends = <Route as DeliveryRoute>::Sends

type Ph = Never

type Error = Never

type Birth = NoBirths

fn transition( &mut self, _: ActiveTurn, event: Self::Event, ) -> BehaviorActed<Self>

Fold exactly one event into explicit actions and the next behavior.

fn init( &mut self, _turn: InitializationTurn, ) -> Result<Actions<<Self::Protocol as Protocol>::Addr, Self::Ph, Self::Sends, Self::Birth>, Self::Error>

where Self: Sized,

Produce initialization actions before the first event is accepted.

fn layer<L>(self, layer: L) -> <L as BehaviorLayer<Self>>::Output

where Self: Sized, L: BehaviorLayer<Self>,

Apply one statically dispatched construction layer.

impl<A, K, P, Route> BehaviorBase for Acknowledgements<A, K, P, Route>

where A: Address, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = AcknowledgementOutcome<K, P>>>,

type Base = Acknowledgements<A, K, P, Route>

fn base(&self) -> &Self

impl<A, K, P, Route> Default for Acknowledgements<A, K, P, Route>

where A: Address, K: Clone + Eq, P: Clone + Eq, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = AcknowledgementOutcome<K, P>>>,

fn default() -> Self

Returns the “default value” for a type.

impl<A, K, P, Route> Protocol for Acknowledgements<A, K, P, Route>

where A: Address, Route: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = AcknowledgementOutcome<K, P>>>,

type Addr = A

type Msg = AcknowledgementMessage<K, P, Route>