Module message_queues 

Message queue implementations.

These are in-memory data structures used by the mailbox. They are !Send outside their owning ActorCell — all external sending goes through the typed channel held in crate::actor::ActorRef.

Structs

BoundedMsgQueue

Bounded FIFO queue.

ControlAwareQueue

DequeQueue

Deque-like queue permitting front insertion (for stash/unstash).

PriorityQueue

Priority queue.

StablePriorityQueue

Stable priority queue (FIFO among equal priorities).

UnboundedQueue

Unbounded FIFO queue.

Enums

ControlAware

Control-aware queue. Control messages are drained before user messages regardless of insertion order. UnboundedControlAwareMessageQueue. Use the typed wrapper ControlAware::Control / ControlAware::User to tag a message.

PushOutcome

Outcome of a bounded push once an OverflowStrategy has been applied. Accepted means the message was enqueued (possibly after dropping another); Rejected(msg) means the configured strategy refused the push and returns the original message.

Traits

Prioritized

Envelope trait used by priority queues.