Enum BackpressureControl 

pub enum BackpressureControl {
    DropLatestIncomingIfBufferFull,
    BlockUntilBufferHasSpace,
}

Controls how a single-subscriber stream reacts when its in-memory buffer fills up.

Variants

DropLatestIncomingIfBufferFull

Drop newly read chunks whenever the in-memory buffer is full.

This keeps the stream reader moving and avoids backpressuring the child process, but a slow consumer may miss output.

BlockUntilBufferHasSpace

Wait for buffer space instead of dropping chunks.

This avoids losing output inside the library, but it can slow down stream consumption. If the child process writes faster than the consumer can keep up, the OS pipe may fill and backpressure the child process itself.

Trait Implementations

impl Clone for BackpressureControl

fn clone(&self) -> BackpressureControl

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BackpressureControl

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

Formats the value using the given formatter.

impl PartialEq for BackpressureControl

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

impl Eq for BackpressureControl

impl StructuralPartialEq for BackpressureControl