Struct ChainMpscProducer 

pub struct ChainMpscProducer { /* private fields */ }

MPSC producer handle over an explicit (pool, queue) pair.

This is a building block for layouts that embed multiple MPSC queues sharing the same slot pool.

Implementations

impl ChainMpscProducer

pub fn publish(&self, data: &[u8]) -> Result<(), Error>

Publish a byte payload.

pub fn publish_with<F, E>(&self, f: F) -> Result<(), PublishWithError<E>>

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

Publish by writing directly into the slot buffer.

pub fn try_publish_slot(&self, slot: EventsSlot) -> Result<(), PublishSlotError>

Publish a previously-received slot by forwarding its slot index into this producer’s queue.

pub fn publish_slot(&self, slot: EventsSlot) -> Result<(), Error>

Publish a previously-received slot, discarding it on failure.

Trait Implementations

impl Send for ChainMpscProducer

impl Sync for ChainMpscProducer