Struct BlockingMpscProducer 

pub struct BlockingMpscProducer { /* private fields */ }

A single producer handle. Sole writer to one underlying SPSC ring. !Sync + !Clone + Send: one producer per thread.

Implementations

impl BlockingMpscProducer

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

Non-blocking push. On success, increments the shared total_published counter and fires a wake at the consumer waker (cheap if no parked consumer).

pub fn send_blocking( &self, payload: &[u8], timeout: Option<Duration>, ) -> Result<(), BlockingError>

Block until either push succeeds or timeout elapses. Producer parks on its OWN ring’s waker; the consumer’s pop-side wakes the right ring’s waker by try_pop_ring_blocking.

pub fn capacity(&self) -> usize

This producer’s ring capacity (constant).

pub fn head(&self) -> u64

This producer’s own publish head.