Struct StreamEnd 

pub struct StreamEnd {
    pub reason: EndReason,
    pub cursor: u64,
}

Why a stream stopped, and where a resume would pick up.

Returned by ExecHandle::for_each_event and ExecHandle::for_each_event_async so the three endings are distinguishable without a caller having to reason about which event it last saw. That distinction is the whole point of this module — a body that ended without an exit event was cut, and the byte sequence alone cannot say so — and asking every caller to re-derive it from a tally is how one of them gets it wrong and reports a truncated stream as a clean pass.

Fields

reason: EndReason

cursor: u64

The offset a resume would pass as StreamOptions::offset.

Core’s cursor, not a count of what the callback saw. The two rules in this module’s docs (advance only past delivered bytes, and advance past a gap) are obeyed by the state machine below; handing the number back means a caller resuming does not maintain a second cursor that disagrees with this one exactly when a reconnect happened.

Trait Implementations

impl Clone for StreamEnd

fn clone(&self) -> StreamEnd

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for StreamEnd

impl Debug for StreamEnd

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

Formats the value using the given formatter.

impl Eq for StreamEnd

impl PartialEq for StreamEnd

fn eq(&self, other: &StreamEnd) -> bool

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for StreamEnd