Struct SimplePipeline 

pub struct SimplePipeline<T> { /* private fields */ }

Simpler pipeline with shared state (not type-safe across stages)

Implementations

impl<T> SimplePipeline<T>

where T: Send + 'static,

pub fn new() -> Self

Create a new simple pipeline

pub fn stage<F>(self, transform: F) -> Self

where F: Fn(&mut T) + Send + Sync + 'static,

Add a stage that mutates the data

pub fn execute(&self, data: T) -> T

Execute the pipeline

pub fn build_taskflow( &self, taskflow: &mut Taskflow, data: Arc<Mutex<T>>, ) -> Vec<TaskHandle>

Build as taskflow stages

Trait Implementations

impl<T> Default for SimplePipeline<T>

where T: Send + 'static,

fn default() -> Self

Returns the “default value” for a type.