Struct OrderGate 

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

Deterministic explicit ordered-release policy.

Before a key is open, one value may be retained for it. Opening is strictly monotonic and atomically releases all retained keys at or below the new watermark in key order. Values submitted at an open key are delivered immediately. Duplicate holds return ownership and never overwrite. A stale opening changes nothing. Initialization is empty, no actors are created, and the host never terminates by policy. Inclusive watermark semantics and deterministic release order are Bombay policy; physical delivery remains a runtime responsibility. Transitions have no semantic panic condition.

Implementations

impl<A, K, T, TargetRoute, ReplyRoute> OrderGate<A, K, T, TargetRoute, ReplyRoute>

where A: Address, K: Clone + Ord, TargetRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = T>>, ReplyRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = OrderGateOutcome<K, T>>>,

pub const fn new() -> Self

Construct a closed gate with no retained values.

pub fn state(&self) -> OrderGateState<K>

Return the complete observable gate state.

Trait Implementations

impl<A, K, T, TargetRoute, ReplyRoute> Behavior for OrderGate<A, K, T, TargetRoute, ReplyRoute>

where A: Address, K: Clone + Ord, TargetRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = T>>, ReplyRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = OrderGateOutcome<K, T>>>, TargetRoute::Sends: SendsFor<User<A, OrderGateMessage<K, T, TargetRoute, ReplyRoute>>>, ReplyRoute::Sends: SendsFor<User<A, OrderGateMessage<K, T, TargetRoute, ReplyRoute>>>,

type Protocol = OrderGate<A, K, T, TargetRoute, ReplyRoute>

Stable public communication identity owned by this actor template.

type Event = User<A, <<OrderGate<A, K, 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, K, T, TargetRoute, ReplyRoute> BehaviorBase for OrderGate<A, K, T, TargetRoute, ReplyRoute>

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

type Base = OrderGate<A, K, T, TargetRoute, ReplyRoute>

fn base(&self) -> &Self

impl<A, K, T, TargetRoute, ReplyRoute> Default for OrderGate<A, K, T, TargetRoute, ReplyRoute>

where A: Address, K: Clone + Ord, TargetRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = T>>, ReplyRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = OrderGateOutcome<K, T>>>,

fn default() -> Self

Returns the “default value” for a type.

impl<A, K, T, TargetRoute, ReplyRoute> Protocol for OrderGate<A, K, T, TargetRoute, ReplyRoute>

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

type Addr = A

type Msg = OrderGateMessage<K, T, TargetRoute, ReplyRoute>