Enum BackpressureOutcome 

pub enum BackpressureOutcome {
    Accepted,
    DroppedNewest,
    DroppedOldest,
    Blocked,
    TimedOut,
    Rejected,
    Closed,
}

Result a producer observes when it offers a packet to a buffered stream.

Variants

Accepted

The packet was buffered.

DroppedNewest

The buffer was full and this newest packet was dropped.

DroppedOldest

The buffer was full and the oldest buffered packet was dropped to admit this one.

Blocked

The producer is blocked until capacity frees up.

TimedOut

The offer timed out before capacity freed up.

Rejected

The offer was rejected by policy.

Closed

The stream is closed and accepts no further packets.

Implementations

impl BackpressureOutcome

pub fn wire_label(self) -> &'static str

Returns the stable wire label for this outcome.

pub fn symbol(self) -> Symbol

Returns the stream/backpressure/<label> symbol for this outcome.

pub fn from_symbol(symbol: &Symbol) -> Result<Self>

Parses an outcome from its bare or stream/backpressure-qualified symbol.

Returns an error for an unrecognized outcome symbol.

Trait Implementations

impl Clone for BackpressureOutcome

fn clone(&self) -> BackpressureOutcome

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for BackpressureOutcome

impl Debug for BackpressureOutcome

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

Formats the value using the given formatter.

impl Eq for BackpressureOutcome

impl PartialEq for BackpressureOutcome

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