Trait StreamOperator 

pub trait StreamOperator: StreamProcessor {
    // Required method
    fn name(&self) -> &str;
}

Stream operator trait

Required Methods

fn name(&self) -> &str

Get operator name

Implementors

impl<F> StreamOperator for FilterOperator<F>

where F: Fn(&Value) -> bool + Send + Sync,

impl<F> StreamOperator for MapOperator<F>

where F: Fn(Value) -> Value + Send + Sync,

impl<F, Fut> StreamOperator for AsyncMapOperator<F, Fut>

where F: Fn(Value) -> Fut + Send + Sync, Fut: Future<Output = Value> + Send,

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

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