Enum SubscriptionItem 

pub enum SubscriptionItem {
    Snapshot(Box<SessionSnapshot>),
    Event(EventEnvelope<RealtimeEvent>),
    ResyncRequired,
}

Items a subscription yields: the authoritative Snapshot first, then live Events. ResyncRequired appears when the consumer lagged past the broadcast capacity; the following next() returns a fresh Snapshot. Events between the initial registration and the snapshot (or spanning a resync) can be delivered both in a snapshot and as events; consumers dedupe by (revision, run_seq) (SPEC §5.3 allows this interpretation).

Variants

Snapshot(Box<SessionSnapshot>)

Event(EventEnvelope<RealtimeEvent>)

ResyncRequired