Struct BoundedLiveQueue 

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

Bounded queue used at live audio/control boundaries.

Implementations

impl<T> BoundedLiveQueue<T>

pub fn with_capacity(bound: usize) -> Result<Self>

Creates a queue bounded to bound items, rejecting a zero bound.

pub fn push(&mut self, item: T) -> LiveQueuePush

Pushes an item, dropping the newest under backpressure when full.

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

Removes and returns the oldest item, if any.

pub fn len(&self) -> usize

Returns the number of queued items.

pub fn is_empty(&self) -> bool

Returns whether the queue is empty.

pub fn capacity(&self) -> usize

Returns the configured capacity bound.

pub fn allocated_capacity(&self) -> usize

Returns the backing buffer’s allocated capacity.

pub fn dropped(&self) -> u64

Returns the count of items dropped since the last take_dropped.

pub fn take_dropped(&mut self) -> u64

Returns and clears the pending dropped-item count.

pub fn stats(&self) -> StreamStats

Returns a snapshot of the queue’s stream statistics.

Trait Implementations

impl<T: Clone> Clone for BoundedLiveQueue<T>

fn clone(&self) -> BoundedLiveQueue<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for BoundedLiveQueue<T>

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

Formats the value using the given formatter.