Struct MpscConsumer 

pub struct MpscConsumer { /* private fields */ }

MPSC consumer handle for a SharedLayout events region.

Semantics (v1):

• nonblocking receive (Ok(None) when empty)
• try_recv_with borrows slot bytes only for the duration of the callback

Implementations

impl MpscConsumer

pub fn try_recv_into(&self, out: &mut [u8]) -> Result<Option<usize>, Error>

• Ok(Some(len)) on success
• Ok(None) if queue empty
• Err(BufferTooSmall) if out is too small

pub fn try_recv_with<F, R, E>( &self, f: F, ) -> Result<Option<R>, RecvWithError<E>>

where F: FnOnce(&[u8]) -> Result<R, E>,

Receive by borrowing the slot bytes for the duration of f.

If the callback returns Err, the message is still considered consumed; it will not be re-delivered.

pub fn try_recv_slot(&self) -> Result<Option<EventsSlot>, Error>

Receive a message as an owned slot handle.

The returned slot is valid until it is dropped (which frees it back to the pool) or forwarded via publish_slot.

Trait Implementations

impl Send for MpscConsumer