Struct SpscConsumer 

pub struct SpscConsumer<T, const CAP: usize> { /* private fields */ }

Consumer half of the lock-free SPSC ring buffer.

Implementations

impl<T, const CAP: usize> SpscConsumer<T, CAP>

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

Attempts to pop an item from the ring buffer.

Returns Some(item) if an element is available, or None if the buffer is empty.

pub fn drain_batch(&self, out: &mut Vec<T>, max: usize) -> usize

Drains up to max items from the ring buffer into the provided out vector.

Returns the number of items drained.

pub fn is_empty(&self) -> bool

Returns true if the ring buffer contains no items.

Trait Implementations

impl<T, const CAP: usize> Debug for SpscConsumer<T, CAP>

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

Formats the value using the given formatter.

impl<T, const CAP: usize> Drop for SpscConsumer<T, CAP>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

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

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.