Struct OperatorChain 

pub struct OperatorChain { /* private fields */ }

Chain of operators that can be applied sequentially

Implementations

impl OperatorChain

pub fn new() -> Self

Create a new operator chain

pub fn add<O: StreamOperator + 'static>(&mut self, operator: O)

Add an operator to the chain

pub fn operators(&self) -> &[Arc<dyn StreamOperator>]

Get all operators in the chain

pub async fn process( &self, input: Vec<Vec<u8>>, ctx: &OperatorContext, ) -> Result<Vec<Vec<u8>>>

Process an event through the entire operator chain

pub fn len(&self) -> usize

Get the number of operators in the chain

pub fn is_empty(&self) -> bool

Check if the chain is empty

Trait Implementations

impl Debug for OperatorChain

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

Formats the value using the given formatter.

impl Default for OperatorChain

fn default() -> Self

Returns the “default value” for a type.