Struct StreamStats 

pub struct StreamStats {
    pub pushed: u64,
    pub accepted: u64,
    pub yielded: u64,
    pub dropped_newest: u64,
    pub dropped_oldest: u64,
    pub overflow_errors: u64,
    pub rejected: u64,
    pub timeouts: u64,
    pub timed_out: u64,
    pub blocked: u64,
    pub closed: bool,
    pub cancelled: bool,
}

Lifetime counters observed on a stream spine.

Every field accumulates over the life of the stream and is snapshotted by StreamValue::stats; the two boolean flags record terminal state. The counters are advanced by the queue as packets are pushed, yielded, dropped, or rejected, giving a behavioral record of how backpressure played out.

Fields

pushed: u64

Total packets handed to the spine via push, regardless of outcome.

accepted: u64

Packets admitted to the queue (excludes drops, rejects, and closed pushes).

yielded: u64

Packets pulled out of the spine and handed to a consumer.

dropped_newest: u64

Packets dropped on overflow under the drop-newest policy.

dropped_oldest: u64

Packets evicted from the front on overflow under the drop-oldest policy.

overflow_errors: u64

Overflows that occurred while the error policy was in force.

rejected: u64

Pushes refused (returned as PushResult::Rejected).

timeouts: u64

Timed waits that elapsed without a packet becoming available.

timed_out: u64

Timed pulls that returned empty because the wait timed out.

blocked: u64

Pulls that had to block waiting for a packet.

closed: bool

Whether the stream has been closed to further input.

cancelled: bool

Whether the stream was cancelled (closed and drained of buffered items).

Trait Implementations

impl Clone for StreamStats

fn clone(&self) -> StreamStats

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamStats

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

Formats the value using the given formatter.

impl Default for StreamStats

fn default() -> StreamStats

Returns the “default value” for a type.

impl Eq for StreamStats

impl PartialEq for StreamStats

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