Enum Event 

#[non_exhaustive]
pub enum Event<T> {
    Push {
        index: u64,
        value: T,
    },
    Pop(Range<u64>),
    Skip(Range<u64>),
}

One change to the window, as the consumer sees it.

A record is Pushed when it first reaches this consumer. Contiguous ranges are Popped when they leave the window or Skipped when they were dropped before this consumer saw them.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Push

This record joined the window, at this absolute index.

Fields

index: u64

Absolute index assigned to the record.

value: T

The decoded record.

Pop(Range<u64>)

These records left the window.

Skip(Range<u64>)

These records existed but will never be delivered: they were pushed and dropped while this consumer was behind.

Trait Implementations

impl<T: Clone> Clone for Event<T>

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for Event<T>

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

Formats the value using the given formatter.

impl<T: PartialEq> PartialEq for Event<T>

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

Equality operator ==.

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

Inequality operator !=.

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