Struct ScanOperator 

pub struct ScanOperator<F>
where
    F: FoldFunction,
{ /* private fields */ }

Scan operator (like fold but emits intermediate results).

Implementations

impl<F> ScanOperator<F>

where F: FoldFunction,

pub fn new(fold_fn: F, initial_value: Vec<u8>) -> Self

Create a new scan operator.

pub async fn process( &self, element: StreamElement, ) -> Result<Vec<StreamElement>>

Process an element.

pub async fn clear(&self)

Clear all state.