Struct TypedFanoutConsumer 

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

Typed fanout consumer that decodes v1-framed messages using codec C.

See TypedSpscReceiver for receive-side partial-effect semantics.

Implementations

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

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

Wrap an indexbus-core fanout consumer with a codec.

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

pub fn try_recv_borrowed_with<T, F, R>( &self, meta: MsgMeta, f: F, ) -> Result<Option<R>, Error>

where C: CodecId + DecodeBorrowed<T>, F: for<'a> FnMut(Header, <C as DecodeBorrowed<T>>::View<'a>) -> Result<R, Error>,

Receive a typed borrowed view and process it within f.

See TypedSpscReceiver::try_recv_borrowed_with for partial-effect semantics.

pub fn try_recv_borrowed_msg_with<T, F, R>( &self, f: F, ) -> Result<Option<R>, Error>

where T: IndexbusMsgSpec, C: CodecId + DecodeBorrowed<T>, F: for<'a> FnMut(Header, <C as DecodeBorrowed<T>>::View<'a>) -> Result<R, Error>,

Receive a typed borrowed view using compile-time identity (T::META).

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

pub fn try_recv_owned<T>( &self, meta: MsgMeta, ) -> Result<Option<(Header, T)>, Error>

where C: CodecId + DecodeFrom<T>,

Receive and decode a typed owned value.

Returns Ok(None) when empty (or when the consumer index is out of range).

See TypedSpscReceiver::try_recv_owned for partial-effect semantics.

pub fn try_recv_owned_msg<T>(&self) -> Result<Option<(Header, T)>, Error>

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

Receive a typed owned value using compile-time identity (T::META).