Struct BlockingMpmcConsumer 

pub struct BlockingMpmcConsumer { /* private fields */ }

One consumer handle. Sole drainer of an assigned subset of producer rings (round-robin from the factory). !Sync + !Clone + Send.

Implementations

impl BlockingMpmcConsumer

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

Non-blocking pop, round-robin across this consumer’s subset.

pub fn recv_blocking( &self, out: &mut [u8], timeout: Option<Duration>, ) -> Result<usize, BlockingError>

Block until either a pop succeeds or timeout elapses.

pub fn n_rings(&self) -> usize

Number of rings in this consumer’s subset.

pub fn approx_subset_len(&self) -> usize

Approximate pending items across this consumer’s subset.