Struct TypedFanoutProducer 

pub struct TypedFanoutProducer<const N: usize, C> { /* private fields */ }

Typed fanout SPSC producer that publishes into the producer→router queue.

Implementations

impl<const N: usize, C> TypedFanoutProducer<N, C>

pub fn new(inner: FanoutProducer<N>, codec: C) -> Self

Wrap an indexbus-core fanout producer with a codec.

impl<const N: usize, C> TypedFanoutProducer<N, C>

pub fn publish<T>(&self, meta: MsgMeta, value: &T) -> Result<(), Error>

where C: CodecId + EncodeInto<T>,

Publish value with the provided message identity.

pub fn publish_msg<T>(&self, value: &T) -> Result<(), Error>

where T: IndexbusMsgSpec, C: CodecId + EncodeInto<T>,

Publish a typed message using compile-time identity (T::META).