async-pipeline

Easy way to pipeline sync and async functions

Example

```rust use asyncpipeline::begin; use asyncpipeline::link::{Linkable, Pipeline}; use async_pipeline::Error; use std::time::Duration; use tokio::time::sleep;

fn square(n: i32) -> String { (n * n).to_string() }

fn from_str(n: String) -> Result { Ok(n.parse::()?) }

[tokio::main]

async fn main() { let pipeline = begin() .then(square) .thenasync(|mut s| async { s.push('9'); println!("wait 1 second"); sleep(Duration::fromsecs(1)).await; s }) .thenresult(fromstr) .thenasyncresult(|i| async move { match i % 7 { 0 => Err("inject error".into()), _ => Ok(i), } }) .then(|i| { println!("last step"); i }); let r1 = pipeline.process(2).await; println!("{}", r1.err().unwrap()); //assert!(r1.err().unwrap()); let r2 = pipeline.process(3).await; println!("{}", r2.unwrap()); }

```