Enum TopicOverflow 

pub enum TopicOverflow {
    Backpressure,
    Sliding,
    Dropping,
}

Overflow policy for each Topic subscriber buffer.

Variants

Backpressure

Preserve every element for every active subscriber.

publish(value).await waits until every subscriber in the publish snapshot has capacity, then enqueues the element to all of them in the topic’s global publish order. try_publish(value) returns TopicTryPublishError::Full instead of waiting if any subscriber in the snapshot is full.

Sliding

Keep the newest bounded window per subscriber.

When a subscriber buffer is full, publishing drops that subscriber’s oldest queued element and enqueues the new element. Other subscribers are unaffected. Publishers never wait for subscriber capacity under this policy.

Dropping

Drop new elements for slow subscribers.

When a subscriber buffer is full, the new element is skipped for that subscriber only. Other subscribers still receive it. Publishers never wait for subscriber capacity under this policy.

Trait Implementations

impl Clone for TopicOverflow

fn clone(&self) -> TopicOverflow

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for TopicOverflow

impl Debug for TopicOverflow

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

Formats the value using the given formatter.

impl Eq for TopicOverflow

impl PartialEq for TopicOverflow

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