Struct TypedSpscSender 

pub struct TypedSpscSender<C> { /* private fields */ }

Typed SPSC sender that publishes v1-framed messages using codec C.

Contract

• Publishes a v1 header prefix (indexbus_msg) plus codec-defined payload bytes.
• If encoding fails, no message is published.

Implementations

impl<C> TypedSpscSender<C>

pub fn new(inner: SpscSender, codec: C) -> Self

Wrap an indexbus-core SPSC sender with a codec.

impl<C> TypedSpscSender<C>

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

where C: CodecId + EncodeInto<T>,

Publish value with the provided message identity.

This encodes a v1 header into the slot prefix, encodes value into the payload region, and publishes the resulting slot bytes.

Errors

• Error::TooLarge: the encoded payload does not fit in a single slot.
• Error::Codec/Error::Envelope: encoding failed.

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).

This is sugar over Self::publish. Use publish(meta, value) if you need dynamic identity or non-default flags.