Enum SlowSubscriberPolicy 

pub enum SlowSubscriberPolicy {
    Block,
    DropSlow,
    SkipForSlow,
}

Slow subscriber handling policy.

Determines what happens when the slowest subscriber is too far behind the producer (about to overwrite unread data).

Variants

Block

Block producer until slow subscriber catches up (default).

Best for exactly-once semantics where no data loss is acceptable. May cause head-of-line blocking if one subscriber is permanently slow.

DropSlow

Drop the slowest subscriber and continue.

Best for systems where continuing is more important than any single subscriber. The dropped subscriber receives a disconnection signal.

SkipForSlow

Skip messages for slow subscribers (they lose data).

Best for real-time systems where freshness matters more than completeness. Slow subscribers simply miss events.

Trait Implementations

impl Clone for SlowSubscriberPolicy

fn clone(&self) -> SlowSubscriberPolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SlowSubscriberPolicy

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

Formats the value using the given formatter.

impl Default for SlowSubscriberPolicy

fn default() -> SlowSubscriberPolicy

Returns the “default value” for a type.

impl PartialEq for SlowSubscriberPolicy

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

impl Eq for SlowSubscriberPolicy

impl StructuralPartialEq for SlowSubscriberPolicy