Struct Decoded 

pub struct Decoded<T> {
    pub event: T,
    pub version: Version,
    pub metadata: Option<Bytes>,
}

A raw envelope, un-packed: the decoded event plus its resume bookmark and metadata. T is the owned event (E) on the stream path, or the borrowed window (Decode::Output) inside a fold closure.

Fields

event: T

The decoded event (owned E, or a borrowed window).

version: Version

The per-stream version — the per-stream resume bookmark.

metadata: Option<Bytes>

The event’s metadata, if any (cheap Arc-shared bytes).

Trait Implementations

impl<T: Clone> Clone for Decoded<T>

fn clone(&self) -> Decoded<T>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug> Debug for Decoded<T>

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

Formats the value using the given formatter.

impl<T: Eq> Eq for Decoded<T>

impl<T: PartialEq> PartialEq for Decoded<T>

fn eq(&self, other: &Decoded<T>) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl<E> Positioned for Decoded<E>

type Event = E

The decoded event type carried by the item.

type Pos = Version

The position type the stepper checkpoints at.

fn into_parts(self) -> (Version, Option<StreamKey>, Self)

Split the item into its bookmark, its origin-stream attribution ($all items only), and the decoded box.

impl<T: PartialEq> StructuralPartialEq for Decoded<T>