Struct PipelineExecutorN 

pub struct PipelineExecutorN { /* private fields */ }

N-stage heterogeneous executor.

Implementations

impl PipelineExecutorN

pub fn new() -> Self

pub fn push<S: PipelineStage>(self, stage: S) -> Self

pub async fn run<I, O>( &mut self, streams: &[Arc<CudaStream>], completion: &Arc<dyn CompletionStrategy>, input: I, ) -> Result<O, GpuError>

where I: Send + 'static, O: Send + 'static,

Run the chain across streams (one per stage). On success returns the tail stage’s output. On any stage failure, the error short-circuits the chain.

pub fn stage_count(&self) -> usize

Trait Implementations

impl Default for PipelineExecutorN

fn default() -> Self

Returns the “default value” for a type.