unipipe 0.2.4

A simple Rust pipe abstraction that extends to iterator and stream.
Documentation 
1
2
3
4
5
6
7
8
9
10
11

pub use async_stream::stream;
pub use futures::{Stream, StreamExt};

pub use unipipe_macros::*;

pub trait UniPipe {
    type Input;
    type Output;

    fn next(&mut self, input: Option<Self::Input>) -> Option<Self::Output>;
}