Struct MessagePriorityQueue 

pub struct MessagePriorityQueue { /* private fields */ }

Priority queue for messages

Messages are ordered by priority (0-9, higher = more important), with FIFO ordering within the same priority level.

Implementations

impl MessagePriorityQueue

pub fn new() -> Self

Create a new priority queue

pub fn with_capacity(max_size: usize) -> Self

Create a priority queue with a maximum size

pub fn push(&mut self, message: Message) -> bool

Push a message onto the queue

Returns true if the message was added, false if the queue is full

pub fn pop(&mut self) -> Option<Message>

Pop the highest priority message from the queue

pub fn peek(&self) -> Option<&Message>

Peek at the highest priority message without removing it

pub fn len(&self) -> usize

Get the number of messages in the queue

pub fn is_empty(&self) -> bool

Check if the queue is empty

pub fn is_full(&self) -> bool

Check if the queue is full (if max_size is set)

pub fn clear(&mut self)

Clear all messages from the queue

pub fn drain(&mut self) -> Vec<Message>

Drain all messages from the queue in priority order

pub fn filter_by_priority(&self, priority: u8) -> Vec<&Message>

Get messages with a specific priority

pub fn count_by_priority(&self) -> [usize; 10]

Count messages by priority level

Trait Implementations

impl Clone for MessagePriorityQueue

fn clone(&self) -> MessagePriorityQueue

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MessagePriorityQueue

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for MessagePriorityQueue

fn default() -> Self

Returns the “default value” for a type.

impl Extend<Message> for MessagePriorityQueue

fn extend<T: IntoIterator<Item = Message>>(&mut self, iter: T)

Extends a collection with the contents of an iterator.

fn extend_one(&mut self, item: A)

🔬This is a nightly-only experimental API. (extend_one)

Extends a collection with exactly one element.

fn extend_reserve(&mut self, additional: usize)

🔬This is a nightly-only experimental API. (extend_one)

Reserves capacity in a collection for the given number of additional elements.

impl FromIterator<Message> for MessagePriorityQueue

fn from_iter<T: IntoIterator<Item = Message>>(iter: T) -> Self

Creates a value from an iterator.

impl IntoIterator for MessagePriorityQueue

type Item = Message

The type of the elements being iterated over.

type IntoIter = PriorityQueueIter

Which kind of iterator are we turning this into?

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value.