Struct TypedMpscConsumer 

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

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

See TypedSpscReceiver for receive-side partial-effect semantics.

Implementations

impl<C> TypedMpscConsumer<C>

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

Wrap an indexbus-core MPSC consumer with a codec.

impl<C> TypedMpscConsumer<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<C> TypedMpscConsumer<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 the queue is empty. On success returns the decoded v1 header and decoded value.

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