Enum BackpressurePolicy 

pub enum BackpressurePolicy {
    DropOldest,
    DegradeQuality,
    PauseUpstream,
    Fail,
}

The four strategies the runtime knows how to execute when a producer outruns its consumer. See also [crate::stream_runtime] for the runtime impls.

Variants

DropOldest

Drop the oldest item to make room for a fresh one. Used for “keep only the most recent” telemetry streams.

DegradeQuality

Apply a pure degradation function (e.g. resample audio to a lower bitrate) so the downstream consumer still gets every frame, just lossy. The degrader is declared via degrade_quality(resample_to=8000) syntax.

PauseUpstream

Block the producer until the buffer drains. Safe for request/response flows but MUST NOT be used on real-time ingest paths (microphones, market data) or the source hangs.

Fail

Raise an error and cancel the stream. Forces callers to deal with saturation as an explicit failure mode. The default-is- no-default: a Stream<T> without a declared policy never falls back to Fail; it fails to compile.

Implementations

impl BackpressurePolicy

pub const ALL: &'static [BackpressurePolicy]

Every variant. Explicit slice so adding a policy without updating consumers is a compile error.

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

pub fn from_slug(slug: &str) -> Option<BackpressurePolicy>

Trait Implementations

impl Clone for BackpressurePolicy

fn clone(&self) -> BackpressurePolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for BackpressurePolicy

impl Debug for BackpressurePolicy

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

Formats the value using the given formatter.

impl Display for BackpressurePolicy

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

Formats the value using the given formatter.

impl Eq for BackpressurePolicy

impl Hash for BackpressurePolicy

fn hash<__H>(&self, state: &mut __H)

where __H: Hasher,

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for BackpressurePolicy

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