Enum Delivery 

pub enum Delivery {
    Event(Arc<ExecutionEvent>),
    Lagged {
        dropped: u64,
    },
}

What a subscriber receives.

Variants

Event(Arc<ExecutionEvent>)

One event, in order.

Lagged

The subscriber fell behind and events were dropped rather than buffered. It must read the snapshot and the history again from the sequence it last saw.

Fields

dropped: u64

How many events were dropped.

Trait Implementations

impl Clone for Delivery

fn clone(&self) -> Delivery

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Delivery

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

Formats the value using the given formatter.

impl Eq for Delivery

impl PartialEq for Delivery

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

Tests for self and other values to be equal, and is used by ==.

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

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for Delivery