Struct Pipeline

pub struct Pipeline<Ctx> { /* private fields */ }

A sequentially executed pipeline

Implementations

impl<Ctx> Pipeline<Ctx>

where Ctx: Send + Sync + 'static,

pub fn new( plugs: Vec<Box<dyn Plug<Ctx>>>, executed: Option<Vec<String>>, ) -> Self

create a new pipeline

pub fn execute( self, ctx: Ctx, ) -> Pin<Box<dyn Future<Output = PipelineResponse<Ctx>> + Send>>

execute the entire pipeline sequentially and run to completion

Trait Implementations

impl<Ctx: Default> Default for Pipeline<Ctx>

fn default() -> Pipeline<Ctx>

Returns the “default value” for a type.