Enum SinkWriteErrorAction 

pub enum SinkWriteErrorAction {
    Stop,
    Continue,
}

Action to take after an async writer sink rejects collected output.

Variants

Stop

Stop collection and surface the SinkWriteError as the consumer’s output. The writer-backed consumer’s wait returns Ok(Err(sink_write_error)) in that case.

Continue

Accept the individual write failure and keep collecting later stream output.

Trait Implementations

impl Clone for SinkWriteErrorAction

fn clone(&self) -> SinkWriteErrorAction

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SinkWriteErrorAction

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

Formats the value using the given formatter.

impl PartialEq for SinkWriteErrorAction

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

impl Eq for SinkWriteErrorAction

impl StructuralPartialEq for SinkWriteErrorAction