Struct FanoutProducer 

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

SPSC producer handle for a fanout events region.

Publishes into the producer→router queue.

Semantics (v1):

• at-most-once enqueue into the producer queue
• bounded capacity; Error::Full when saturated

Implementations

impl<const N: usize> FanoutProducer<N>

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

Publish a byte payload into the producer→router 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.

The closure must return the number of bytes written. That length becomes the published message length.

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 FanoutProducer<N>