Enum RecvError 

pub enum RecvError {
    Disconnected,
    Lagged {
        skipped: usize,
    },
}

Error returned by blocking recv operations.

Variants

• Disconnected: All senders have been dropped. For broadcast channels, this means no new messages will arrive.

• Lagged { skipped }: Only for bounded broadcast channels. Indicates that the receiver fell behind the sender(s) and missed skipped messages. The receiver’s cursor has been advanced to the oldest available message.

Lag Recovery

When Lagged { skipped } is encountered, the receiver has been automatically advanced to the oldest message still in the ring buffer. Typical recovery patterns:

match rx.recv() {
    Ok(msg) => process(msg),
    Err(RecvError::Lagged { skipped }) => {
        eprintln!("Fell behind by {} messages", skipped);
        // Continue receiving: the next recv() will return the oldest
        // available message, not an error.
    }
    Err(RecvError::Disconnected) => {
        eprintln!("All senders disconnected");
        break;
    }
}

To avoid lag:

• Ensure receiver threads wake promptly (use select! with short timeouts)
• Consider increasing broadcast channel capacity if lag is frequent
• Process messages quickly in the recv handler

Variants

Disconnected

Lagged

Fields

skipped: usize

Trait Implementations

impl Clone for RecvError

fn clone(&self) -> RecvError

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RecvError

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

Formats the value using the given formatter.

impl PartialEq for RecvError

fn eq(&self, other: &RecvError) -> 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 Eq for RecvError

impl StructuralPartialEq for RecvError