Enum StreamInstrumentationState 

pub enum StreamInstrumentationState {
    Running,
    Draining,
    Completed,
    Failed,
}

The externally visible state of one instrumented stream materialization.

Variants

Running

The stream has been materialized and has not reached a terminal state.

Draining

The stream is draining or was dropped before the boundary observed normal completion.

Completed

The boundary observed upstream completion.

Failed

The boundary observed a non-cancellation stream failure.

Trait Implementations

impl Clone for StreamInstrumentationState

fn clone(&self) -> StreamInstrumentationState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for StreamInstrumentationState

impl Debug for StreamInstrumentationState

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

Formats the value using the given formatter.

impl Eq for StreamInstrumentationState

impl PartialEq for StreamInstrumentationState

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