Struct DecodeFailure 

#[non_exhaustive]
pub struct DecodeFailure<E> {
    pub topic: Arc<TopicMatch>,
    pub meta: Arc<MessageMeta>,
    pub error: E,
}

A message arrived but its payload could not be deserialized. Carries the same context as IncomingMessage so a handler can still see which topic (and with what metadata) failed. The stream continues after this event.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

topic: Arc<TopicMatch>

The concrete topic the undecodable message arrived on.

meta: Arc<MessageMeta>

Per-message protocol metadata of the undecodable message.

error: E

The deserialization error.

Implementations

impl<E> DecodeFailure<E>

pub fn new( topic: Arc<TopicMatch>, meta: Arc<MessageMeta>, error: E, ) -> DecodeFailure<E>

Construct a decode failure. Public so downstream tests can build one (the type is #[non_exhaustive], so a struct literal is not available off-crate).

Trait Implementations

impl<E> Debug for DecodeFailure<E>

where E: Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.