Enum Backpressure 

pub enum Backpressure {
    Unbounded,
    Block {
        max_pending: usize,
    },
    KeepLatest {
        max_pending: usize,
    },
}

Queue policy between a producer and a spawned node (ReconNode::spawn).

Variants

Unbounded

Never drop; the queue grows without bound.

Block

send blocks while max_pending states are queued (try_send returns SendError::Full).

Fields

max_pending: usize

Queue capacity.

KeepLatest

Keep the newest states: when max_pending are queued, the oldest queued ready set is dropped (it then shows up as a sequence gap). Capture never waits for reconstruction.

Fields

max_pending: usize

Queue capacity.

Trait Implementations

impl Clone for Backpressure

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for Backpressure

impl Debug for Backpressure

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

Formats the value using the given formatter.

impl Default for Backpressure

fn default() -> Self

Returns the “default value” for a type.

impl Eq for Backpressure

impl PartialEq for Backpressure

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for Backpressure