Struct MpscConsumer 

pub struct MpscConsumer { /* private fields */ }

The single consumer handle. Drains all N producer rings round-robin; !Sync + !Clone + Send so the compiler enforces a single consumer.

Implementations

impl MpscConsumer

pub fn try_pop(&self, out: &mut [u8]) -> Result<usize, RingError>

Drain one item, round-robin across all N producer rings. Returns Ok on the first ring that has an item; Err(Empty) only if every ring is empty.

pub fn n_producers(&self) -> usize

Number of producer rings this consumer drains.

pub fn approx_total_len(&self) -> usize

Total approximate items waiting across all producer rings.