Struct TypedFanoutMpscProducer 

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

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

Implementations

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

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

Wrap an indexbus-core fanout MPSC producer with a codec.

impl<const N: usize, C> TypedFanoutMpscProducer<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).