Struct FoldOperator 

pub struct FoldOperator<F, T>
where
    F: Fn(T, Value) -> T + Send + Sync,
    T: Clone + Send + Sync + 'static,
{
    pub name: String,
    pub initial: T,
    pub func: Arc<F>,
}

Fold operator - accumulates values

Fields

name: String

initial: T

func: Arc<F>

Implementations

impl<F, T> FoldOperator<F, T>

where F: Fn(T, Value) -> T + Send + Sync, T: Clone + Send + Sync + 'static,

pub fn new(name: impl Into<String>, initial: T, func: F) -> Self

Trait Implementations

impl<F, T> StreamOperator for FoldOperator<F, T>

where F: Fn(T, Value) -> T + Send + Sync, T: Clone + Send + Sync + Into<Value> + 'static,

fn name(&self) -> &str

Get operator name

impl<F, T> StreamProcessor for FoldOperator<F, T>

where F: Fn(T, Value) -> T + Send + Sync, T: Clone + Send + Sync + Into<Value> + 'static,

fn process_item<'life0, 'life1, 'async_trait>( &'life0 self, item: Value, _ctx: &'life1 Context, ) -> Pin<Box<dyn Future<Output = RuleResult> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Process a single item from the stream

fn process_chunk<'life0, 'life1, 'async_trait>( &'life0 self, items: Vec<Value>, _ctx: &'life1 Context, ) -> Pin<Box<dyn Future<Output = Result<Vec<Value>, RuleError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Process a chunk of items (for batch operations)