Struct FanoutMpscProducer 

pub struct FanoutMpscProducer<const N: usize> { /* private fields */ }

Multi-producer handle for publishing into a fanout layout.

Publishes into the layout’s MPSC producer->router queue.

Implementations

impl<const N: usize> FanoutMpscProducer<N>

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

Publish a byte payload into the producer→router MPSC queue.

Returns:

• Ok(()) if the message was committed
• Err(Error::TooLarge) if data.len() > INDEXBUS_SLOT_DATA_SIZE
• Err(Error::Full) if bounded capacity is exhausted

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.

Errors

• PublishWithError::Encode: the closure returned an error; no message is published.
• PublishWithError::Core: capacity/layout failures (e.g. full), or len > INDEXBUS_SLOT_DATA_SIZE.

Trait Implementations

impl<const N: usize> Send for FanoutMpscProducer<N>

impl<const N: usize> Sync for FanoutMpscProducer<N>