Struct BlockingMpscConsumer 

pub struct BlockingMpscConsumer { /* private fields */ }

The single consumer handle. Drains all N producer rings round-robin. !Sync + !Clone + Send.

Implementations

impl BlockingMpscConsumer

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

Non-blocking pop, round-robin across all N rings.

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

Block until either a pop succeeds or timeout elapses. Consumer parks on the SHARED consumer waker; any producer’s push fires it.

pub fn n_producers(&self) -> usize

Number of producer rings this consumer drains.

pub fn approx_total_len(&self) -> usize

Approximate total pending items across every ring.