Struct PriorityQueue 

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

Bounded stable immutable-priority queue behavior.

Greater priorities release first and equal priorities preserve FIFO by an explicit insertion token. Full and token-exhausted offers return ownership. Token exhaustion is a distinct admission phase and never wraps; retained values remain releasable. Release emits one value and one factual outcome; empty release emits only Empty. Initialization is empty, no actors are created, and the host never terminates by policy. Capacity, priority order, and FIFO ties are Bombay policy; mailbox priority and backpressure remain Communication concerns. The implementation uses BinaryHeap because accepted priorities are immutable; it does not need priority-queue. No transition has a semantic panic condition.

Implementations

impl<A, T, P, TargetRoute, ReplyRoute> PriorityQueue<A, T, P, TargetRoute, ReplyRoute>

where A: Address, P: Ord, TargetRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = T>>, ReplyRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = PriorityQueueOutcome<T, P>>>,

pub fn new(capacity: usize) -> Result<Self, PriorityQueueConfigError>

Construct an empty positive-capacity queue.

Errors

Returns PriorityQueueConfigError::ZeroCapacity for zero capacity.

pub fn state(&self) -> PriorityQueueState

Return the complete admission phase and depth.

Trait Implementations

impl<A, T, P, TargetRoute, ReplyRoute> Behavior for PriorityQueue<A, T, P, TargetRoute, ReplyRoute>

where A: Address, P: Ord, TargetRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = T>>, ReplyRoute: DeliveryRoute<Protocol: Protocol<Addr = A, Msg = PriorityQueueOutcome<T, P>>>, TargetRoute::Sends: SendsFor<User<A, PriorityQueueMessage<T, P, TargetRoute, ReplyRoute>>>, ReplyRoute::Sends: SendsFor<User<A, PriorityQueueMessage<T, P, TargetRoute, ReplyRoute>>>,

type Protocol = PriorityQueue<A, T, P, TargetRoute, ReplyRoute>

Stable public communication identity owned by this actor template.

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

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

type Base = PriorityQueue<A, T, P, TargetRoute, ReplyRoute>

fn base(&self) -> &Self

impl<A, T, P, TargetRoute, ReplyRoute> Protocol for PriorityQueue<A, T, P, TargetRoute, ReplyRoute>

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

type Addr = A

type Msg = PriorityQueueMessage<T, P, TargetRoute, ReplyRoute>