Struct Pipeline 

pub struct Pipeline { /* private fields */ }

A sequence of stages, itself a Stage. Wired and driven by start (at the top level) or by a parent pipeline’s run (when nested).

Implementations

impl Pipeline

pub fn start(self) -> (PipelineEnds, DriverFuture)

Wire fresh external PipelineEnds and return them with the driving future. The caller drives the future (e.g. block_on) and uses the ends to feed the head and read the tail.

Trait Implementations

impl Processor for Pipeline

type Effect = ()

The command vocabulary this stage can emit; plain data, no I/O.

fn decide_data(&mut self, _frame: &DataFrame) -> Decision<()>

Maps an incoming data frame to a disposition and zero or more effects.

fn decide_system( &mut self, _dir: Direction, _frame: &SystemFrame, ) -> Decision<()>

Maps an incoming system frame to a disposition and zero or more effects.

impl Stage for Pipeline

fn run<'async_trait>( self: Box<Self>, inbound: Inbound, out: Outbound, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait,

Wire the children between inbound and out and drive every child’s run cooperatively as one future via FuturesUnordered.

fn perform<'life0, 'life1, 'async_trait>( &'life0 self, _effect: (), _out: &'life1 Outbound, ) -> Pin<Box<dyn Future<Output = Result<(), StageError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Interpret one effect emitted by decide_* and carry out its I/O, sending any resulting frames through out.