Struct WriteQueue 

pub struct WriteQueue { /* private fields */ }

FIFO queue with a hard message-count capacity.

Implementations

impl WriteQueue

pub fn new(capacity: usize) -> Self

Create a queue holding at most capacity messages. A capacity of 0 is clamped to 1 so the queue is always usable.

pub fn capacity(&self) -> usize

pub fn len(&self) -> usize

pub fn is_empty(&self) -> bool

pub fn is_full(&self) -> bool

pub fn enqueue( &mut self, msg: WriteMsg, ) -> Result<(), (WriteMsg, WriteQueueError)>

Enqueue a message. Returns WriteQueueError::Full without mutating the queue when at capacity (the message is returned to the caller untouched so it can be retried after backpressure clears).

pub fn dequeue(&mut self) -> Option<WriteMsg>

Pop the next message in FIFO order.

Trait Implementations

impl Debug for WriteQueue

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

Formats the value using the given formatter.