Struct CircularBuffer 

pub struct CircularBuffer<T> {
    buffer: Mutex<VecDeque<T>>,
    capacity: usize,
}

A thread-safe circular buffer with FIFO eviction.

When the buffer reaches its capacity, the oldest items are automatically removed to make room for new ones.

Fields

buffer: Mutex<VecDeque<T>>

capacity: usize

Implementations

impl<T> CircularBuffer<T>

pub fn new(capacity: NonZeroUsize) -> Self

Create a new circular buffer with the given capacity.

pub fn push(&self, item: T) -> Option<T>

Push an item into the buffer.

If the buffer is at capacity, the oldest item is evicted and returned.

pub fn len(&self) -> usize

Get the current number of items in the buffer.

pub fn is_empty(&self) -> bool

Check if the buffer is empty.

impl<T: Clone> CircularBuffer<T>

pub fn read(&self) -> Vec<T>

Read all items from the buffer.

Returns a snapshot of current buffer contents in order (oldest first).

Trait Implementations

impl<T> Debug for CircularBuffer<T>

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

Formats the value using the given formatter.