Enum LateDataResult 

pub enum LateDataResult<T> {
    OnTime(T),
    WithinLateness(T),
    Drop,
    SideOutput(T),
}

Result of evaluating whether an element is late.

Variants

OnTime(T)

The element is not late and should be processed normally.

WithinLateness(T)

The element is late but within allowed lateness.

Drop

The element is late and should be dropped.

SideOutput(T)

The element is late and should be redirected to side output.

Implementations

impl<T> LateDataResult<T>

pub fn should_process(&self) -> bool

Returns true if the element should be processed (OnTime or WithinLateness).

pub fn into_processable(self) -> Option<T>

Extracts the element if it should be processed.

pub fn is_side_output(&self) -> bool

Returns true if this is a side output.

pub fn into_side_output(self) -> Option<T>

Extracts the element for side output.

Trait Implementations

impl<T: Clone> Clone for LateDataResult<T>

fn clone(&self) -> LateDataResult<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for LateDataResult<T>

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

Formats the value using the given formatter.

impl<T: PartialEq> PartialEq for LateDataResult<T>

fn eq(&self, other: &LateDataResult<T>) -> 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<T: Eq> Eq for LateDataResult<T>

impl<T> StructuralPartialEq for LateDataResult<T>