Struct SpscProducer 

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

Producer half of a split SpscRing.

Implementations

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

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

Push an item into the ring. See SpscRing::push.

pub fn try_push_or_drop(&self, item: T) -> bool

Push an item, silently dropping it if the ring is full. See SpscRing::try_push_or_drop.

Returns true if enqueued, false if dropped.

pub fn is_full(&self) -> bool

Returns true if the ring is full.

pub fn is_empty(&self) -> bool

Returns true if the ring is currently empty.

pub fn len(&self) -> usize

Number of items currently in the ring (snapshot).

pub fn available(&self) -> usize

Available capacity (free slots).

pub fn capacity(&self) -> usize

Maximum number of items this ring can hold (N - 1).

pub fn fill_ratio(&self) -> f64

Fraction of capacity currently occupied: len / capacity.

Returns a value in [0.0, 1.0]. Useful for backpressure monitoring on the producer side.

Trait Implementations

impl<T: Send, const N: usize> Send for SpscProducer<T, N>