Enum SubscriberStreamGap 

pub enum SubscriberStreamGap {
    Lagged {
        skipped: u64,
    },
    Undecodable,
}

Why a live subscription lost data without disconnecting.

Both cases were previously invisible: alloy-pubsub’s typed subscription stream logs a lagged receiver at debug and continues, and discards an undecodable notification the same way. A consumer whose contract is completeness cannot build on a stream that loses records silently, so these are surfaced and healed instead.

Variants

Lagged

The bounded notification channel overflowed and the transport dropped skipped notifications before this receiver observed them.

This is backpressure, not a transport fault: the subscriber was not draining as fast as the endpoint pushed. Raising SubscriberConfig::log_channel_size is the direct remedy.

Fields

skipped: u64

Notifications the transport dropped.

Undecodable

A notification arrived but did not decode into the expected type.

Treated as lost data rather than skipped, because a filter’s matched set cannot be proven complete while one of its notifications is unreadable.

Implementations

impl SubscriberStreamGap

pub const fn skipped(self) -> Option<u64>

Notifications known to be missing, when the transport reported a count.

pub const fn as_str(self) -> &'static str

Stable snake_case name, suitable for a metrics label.

Trait Implementations

impl Clone for SubscriberStreamGap

fn clone(&self) -> SubscriberStreamGap

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for SubscriberStreamGap

impl Debug for SubscriberStreamGap

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

Formats the value using the given formatter.

impl Display for SubscriberStreamGap

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

Formats the value using the given formatter.

impl Eq for SubscriberStreamGap

impl PartialEq for SubscriberStreamGap

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for SubscriberStreamGap