Struct Sequencer 

pub struct Sequencer<A: Address, T, TargetRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = T>>, ReplyRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = SequencerOutcome<T>>>> { /* private fields */ }

Deterministic gap-buffered ordered-delivery policy.

Sequencer accepts each position at most once, retains future positions in a BTreeMap, and releases only the contiguous run beginning at expected. Stale, duplicate, and exhausted offers return ownership through SequencerOutcome; an accepted value is never overwritten. Delivering Sequence(u64::MAX) moves to the explicit terminal policy state SequencerState::Exhausted rather than wrapping. Initialization is empty, the template creates no actors, and it does not terminate the hosting actor. Ordered release and bounded integer exhaustion are deliberate Bombay policy; mailbox FIFO and physical delivery remain bombay-communication responsibilities. The fold requires no capability beyond ordinary typed sends and has no panic path.

Implementations

impl<A, T, TargetRoute, ReplyRoute> Sequencer<A, T, TargetRoute, ReplyRoute>

where A: Address, TargetRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = T>>, ReplyRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = SequencerOutcome<T>>>,

pub fn new(first: Sequence) -> Self

Construct an empty sequencer beginning at first.

pub fn state(&self) -> SequencerState

Borrow the complete observable lifecycle state.

Trait Implementations

impl<A, T, TargetRoute, ReplyRoute> Behavior for Sequencer<A, T, TargetRoute, ReplyRoute>

where A: Address, TargetRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = T>>, ReplyRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = SequencerOutcome<T>>>, TargetRoute::Sends: SendsFor<User<A, SequencerMessage<T, TargetRoute, ReplyRoute>>>, ReplyRoute::Sends: SendsFor<User<A, SequencerMessage<T, TargetRoute, ReplyRoute>>>,

type Protocol = Sequencer<A, T, TargetRoute, ReplyRoute>

Stable public communication identity owned by this actor template.

type Event = User<A, <<Sequencer<A, T, TargetRoute, ReplyRoute> as Behavior>::Protocol as Protocol>::Msg>

type Sends = DeliveryOutcomes<<TargetRoute as DeliveryRoute>::Sends, <ReplyRoute 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, T, TargetRoute, ReplyRoute> BehaviorBase for Sequencer<A, T, TargetRoute, ReplyRoute>

where A: Address, TargetRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = T>>, ReplyRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = SequencerOutcome<T>>>,

type Base = Sequencer<A, T, TargetRoute, ReplyRoute>

fn base(&self) -> &Self

impl<A, T, TargetRoute, ReplyRoute> Protocol for Sequencer<A, T, TargetRoute, ReplyRoute>

where A: Address, TargetRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = T>>, ReplyRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = SequencerOutcome<T>>>,

type Addr = A

type Msg = SequencerMessage<T, TargetRoute, ReplyRoute>