Skip to main content

Module message_queues

Module message_queues 

Source
Expand description

Message queue implementations. akka.net: Dispatch/MessageQueues.

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 (akka.net: BoundedMessageQueue).
DequeQueue
Deque-like queue permitting front insertion (for stash/unstash). akka.net: UnboundedDequeMessageQueue.
PriorityQueue
Priority queue. akka.net: UnboundedPriorityMessageQueue.
StablePriorityQueue
Stable priority queue (FIFO among equal priorities). akka.net: UnboundedStablePriorityMessageQueue.
UnboundedQueue
Unbounded FIFO queue (akka.net: UnboundedMessageQueue).

Traits§

Prioritized
Envelope trait used by priority queues.