Struct ReactiveReceiver 

pub struct ReactiveReceiver { /* private fields */ }

Consumer half. recv() is an .await-able future that resolves when an item arrives, suspending the task until then - off-thread across threads OR across processes, behind the same call.

Implementations

impl ReactiveReceiver

pub fn recv(&self) -> ReactiveRecv

A future resolving to the next slot’s bytes. Owns clones of the ring + waker slot, so it is Send + 'static.

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

Non-blocking pop, for draining without awaiting.