Enum SubscriptionOverflow 

pub enum SubscriptionOverflow {
    Backpressure,
    DropNew,
    Fail,
}

Overflow policy for a Subscription subscriber buffer.

Variants

Backpressure

Preserve every change by parking the producer on the caller thread until every active subscriber cursor has ring capacity. No actor handler waits for data-plane backpressure.

DropNew

Apply the state transition, but mark the new feed item as dropped for subscribers whose logical cursor is full. This is not lossless for slow subscribers and is intended only when dropping is an explicit part of the chosen contract.

Fail

Apply the state transition, fail subscribers whose logical cursor is full after they drain already-accepted items, and return an error to the acknowledged producer.

Trait Implementations

impl Clone for SubscriptionOverflow

fn clone(&self) -> SubscriptionOverflow

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for SubscriptionOverflow

impl Debug for SubscriptionOverflow

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

Formats the value using the given formatter.

impl Eq for SubscriptionOverflow

impl PartialEq for SubscriptionOverflow

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