Struct SpscConsumer 

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

Consumer half of an SpscRing.

Implementations

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

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

Attempts to pop the next buffered item without blocking.

pub const fn pop_async(&self) -> PopFuture<'_, T, N>

Returns a future that resolves to the next buffered item, or None once the producer has been dropped and the ring is empty.

pub fn buffered_count(&self) -> usize

Returns the current buffered item count.

pub fn capacity(&self) -> usize

Returns the runtime capacity of the ring.

pub fn is_closed(&self) -> bool

Returns true if the producer has been dropped.

pub const fn stream(&self) -> SpscConsumerStream<'_, T, N>

Available on crate feature futures-stream only.

Trait Implementations

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

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

Formats the value using the given formatter.