Trait amber::pipeline::PipelineJoin

pub trait PipelineJoin<T, U> {
    fn setup(
        &mut self, 
        id: usize, 
        rx: Vec<Receiver<PipelineInfo<T>>>, 
        tx: Sender<PipelineInfo<U>>
    );
}

Required Methods

fn setup(
    &mut self,
    id: usize,
    rx: Vec<Receiver<PipelineInfo<T>>>,
    tx: Sender<PipelineInfo<U>>
)

Implementors

• impl PipelineJoin<PathMatch, PathMatch> for PipelineSorter