Struct MpmcConsumer 

pub struct MpmcConsumer { /* private fields */ }

One consumer handle. Sole drainer of a subset of producer rings (round-robin assignment from the factory).

Implementations

impl MpmcConsumer

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

Drain one item from this consumer’s assigned subset of producer rings, round-robin. Returns Ok on the first non-empty ring; Err(Empty) only if every ring in the subset is empty.

pub fn n_rings(&self) -> usize

Number of producer rings assigned to this consumer.

pub fn approx_subset_len(&self) -> usize

Approximate total items waiting across this consumer’s subset.