Struct MapOperator 

pub struct MapOperator<F>
where
    F: Fn(Value) -> Value + Send + Sync,
{
    pub name: String,
    pub func: Arc<F>,
}

Map operator - transforms each item

Fields

name: String

func: Arc<F>

Implementations

impl<F> MapOperator<F>

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

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

Trait Implementations

impl<F> StreamOperator for MapOperator<F>

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

fn name(&self) -> &str

Get operator name

impl<F> StreamProcessor for MapOperator<F>

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

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)