dataflow/pipeline/mod.rs
1mod node;
2pub use node::*;
3mod premade;
4pub use premade::*;
5mod loader;
6pub use loader::*;
7mod connectors;
8pub use connectors::*;
9
10#[cfg(test)]
11mod tests;
12
13#[derive(Clone, Copy)]
14pub struct Pipeline;
15
16impl<I> Node<I> for Pipeline {
17 type Output = I;
18
19 fn process(&mut self, input: I) -> I {
20 input
21 }
22}