Enum HubEvent 

pub enum HubEvent {
    Append {
        pos: Vec<StreamPos>,
        offset: Option<u64>,
        records: Vec<u8>,
    },
    Rewritten {
        fileop: String,
    },
    Behind,
}

What a subscription receives.

Variants

Append

Bytes appended to the file, as published: where they landed per stream (transcripts), the byte offset they were written at when the writer said (terminals), and the bytes themselves.

Fields

pos: Vec<StreamPos>

offset: Option<u64>

records: Vec<u8>

Rewritten

The transcript was replaced, deleted or otherwise rewritten as a whole (fileop).

Fields

fileop: String

Behind

Too much was waiting; nothing more will be queued.

Trait Implementations

impl Clone for HubEvent

fn clone(&self) -> HubEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for HubEvent

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

Formats the value using the given formatter.

impl Eq for HubEvent

impl PartialEq for HubEvent

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for HubEvent