Struct ReactiveSender 

pub struct ReactiveSender { /* private fields */ }

Producer half. try_send publishes the payload and signals the consumer - a direct Waker fire intra-process, an MMF wake cross-process.

Implementations

impl ReactiveSender

pub fn try_send(&self, payload: &[u8]) -> Result<(), RingError>

Push a payload and signal the consumer. Returns Err(Full) when the ring is full (the signal is sent only on a successful push).

pub fn published(&self) -> u64

The producer’s published item count (ring head).