amber 0.6.1

A code search and replace tool
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

use crossbeam::channel::{Receiver, Sender};
use std::time::Duration;

pub enum PipelineInfo<T> {
    SeqBeg(usize),
    SeqDat(usize, T),
    SeqEnd(usize),
    MsgInfo(usize, String),
    MsgDebug(usize, String),
    MsgErr(usize, String),
    MsgTime(usize, Duration, Duration),
}

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

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

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