Enum PushResult 

pub enum PushResult {
    Accepted,
    DroppedNewest(StreamItem),
    DroppedOldest(StreamItem),
    Rejected(StreamItem),
    Closed(StreamItem),
}

Outcome of pushing a single packet into a push stream.

The variant records what the spine did with the packet under the active BufferPolicy. Every variant except PushResult::Accepted carries the packet back so the caller can route the rejected or evicted item elsewhere. Map a result to its kernel-facing BackpressureOutcome with PushResult::outcome.

Variants

Accepted

The packet was admitted to the queue.

DroppedNewest(StreamItem)

The queue was full; this newest packet was dropped under the drop-newest policy.

DroppedOldest(StreamItem)

The queue was full; the oldest queued packet was evicted to make room, and that evicted packet is returned here.

Rejected(StreamItem)

The queue was full and the error policy refused the push; the packet is returned unaccepted.

Closed(StreamItem)

The stream was already closed; the packet is returned unaccepted.

Implementations

impl PushResult

pub fn outcome(&self) -> BackpressureOutcome

Maps this push result to the kernel-facing BackpressureOutcome.

Trait Implementations

impl Clone for PushResult

fn clone(&self) -> PushResult

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PushResult

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

Formats the value using the given formatter.

impl Eq for PushResult

impl PartialEq for PushResult

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