Struct ChainSpscReceiver 

pub struct ChainSpscReceiver { /* private fields */ }

SPSC receiver handle over an explicit (pool, queue) pair.

Implementations

impl ChainSpscReceiver

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

Receive into a caller-provided buffer.

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.

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

Receive a message as an owned slot handle.

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

Convenience: best-effort poll (no error, returns None on empty or failure).

pub fn drain_batch_into(&self, out: &mut [u8], batch: usize) -> usize

Poll and yield a bounded batch of messages, resetting the queue head/tail cache-line state.

This is intentionally minimal; higher layers should use WaitStrategy for idle behavior.

Trait Implementations

impl Send for ChainSpscReceiver