Struct CloneableOperatorFactory 

pub struct CloneableOperatorFactory { /* private fields */ }

Simple factory that clones a prototype chain.

Implementations

impl CloneableOperatorFactory

pub fn new() -> Self

Creates a new factory.

pub fn with_operator<F>(self, factory: F) -> Self

where F: Fn() -> Box<dyn PushOperator> + Send + Sync + 'static,

Adds an operator factory.

pub fn with_pipeline_breakers(self) -> Self

Marks that the chain has pipeline breakers.

Trait Implementations

impl Default for CloneableOperatorFactory

fn default() -> Self

Returns the “default value” for a type.

impl OperatorChainFactory for CloneableOperatorFactory

fn create_chain(&self) -> Vec<Box<dyn PushOperator>>

Creates a new operator chain for a worker.

fn has_pipeline_breakers(&self) -> bool

Returns whether the chain contains pipeline breakers.

fn chain_length(&self) -> usize

Returns the number of operators in the chain.