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}