async_pipeline/
lib.rs

1use std::marker::PhantomData;
2use crate::link::Linkable;
3
4pub mod async_connect;
5pub mod connect;
6pub mod link;
7mod test;
8
9pub type Error = link::Error;
10
11pub fn begin<T>() -> Start<T> {
12    return Start {
13        _p: Default::default(),
14    };
15}
16
17pub struct Start<T> {
18    _p: PhantomData<T>,
19}
20
21impl<IN: Send + Sync> Linkable for Start<IN> {
22    type OUT = IN;
23}