Struct BoundedMsgQueue 

pub struct BoundedMsgQueue<T> { /* private fields */ }

Bounded FIFO queue.

Implementations

impl<T> BoundedMsgQueue<T>

pub fn new(capacity: usize) -> Self

pub fn with_overflow(capacity: usize, overflow: OverflowStrategy) -> Self

pub fn push(&mut self, msg: T) -> Result<(), T>

Legacy push that mirrors the original signature: returns the original message if the queue is full. Equivalent to using OverflowStrategy::Fail.

pub fn push_with_strategy(&mut self, msg: T) -> PushOutcome<T>

Push with the configured overflow strategy applied. Returns PushOutcome::Accepted if the message was enqueued (possibly after dropping another), PushOutcome::Dropped giving back the dropped message when DropHead/DropTail kicked in, or PushOutcome::Rejected when DropNew/Fail refused the push.

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

pub fn is_full(&self) -> bool

pub fn overflow(&self) -> OverflowStrategy

Trait Implementations

impl<T: Debug> Debug for BoundedMsgQueue<T>

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

Formats the value using the given formatter.