Enum AccountedRawEvent 

pub enum AccountedRawEvent {
    Event {
        generation: u64,
        sequence: u64,
        event: RawEvent,
    },
    Lagged {
        generation: u64,
        missed: u64,
    },
    Reconnected {
        previous: u64,
        generation: u64,
    },
    Disconnected {
        generation: u64,
    },
}

Loss-accounted event as delivered by Connection::subscribe_raw_accounted.

Connection::subscribe_raw silently drops any RawEvent a lagging subscriber missed and has no way to signal a reconnect or a dead socket. That is fine for the lenient default, but a capture/replay/monitor consumer built on top of it is silently misled about what it actually saw. AccountedRawEvent is the opt-in, honest alternative: every gap, reconnect, and disconnect is reported explicitly instead of vanishing.

Every variant carries a generation — the Connection::connection_generation active when the variant was produced. generation starts at 1 and bumps by one on every Connection::reconnect; each generation gets its own sequence counter, restarted at 1.

Variants

Event

A CDP event delivered in order.

Fields

generation: u64

Generation this event belongs to.

sequence: u64

Monotonic, per-generation position of this event, starting at 1. Within a single generation, a gap between two observed sequence values equals the missed count of an intervening AccountedRawEvent::Lagged — sequence resumes after a loss rather than resetting. Do NOT compare sequence across a AccountedRawEvent::Reconnected: the counter restarts at 1 for the new generation, and a Lagged’s missed may also count the non-sequenced Reconnected/Disconnected markers, so only same-generation values are comparable.

event: RawEvent

The underlying raw CDP event.

Lagged

This subscriber fell behind the broadcast bus and missed missed events that were subsequently overwritten. Unlike Connection::subscribe_raw, which drops lagged frames without a trace, this variant surfaces the loss explicitly so a consumer can decide how to react (resync, alert, abort) instead of silently missing data.

Fields

generation: u64

Generation active when the loss was detected.

missed: u64

Number of events this subscriber missed.

Reconnected

The connection re-established a fresh WebSocket via Connection::reconnect. sequence resets to 1 for the new generation.

Fields

previous: u64

Generation of the actor that was replaced.

generation: u64

Generation of the newly spawned actor.

Disconnected

The underlying WebSocket died unexpectedly — a Chrome-sent Close frame, a read/write error, or the stream ending — as opposed to a caller-requested Connection::shutdown or a Connection::reconnect. Emitted exactly once per generation’s genuine death; a shutdown or a reconnect never produces this variant.

Fields

generation: u64

Generation whose WebSocket died.

Trait Implementations

impl Clone for AccountedRawEvent

fn clone(&self) -> AccountedRawEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AccountedRawEvent

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

Formats the value using the given formatter.