unipipe 0.2.6

A simple Rust pipe abstraction that extends to iterator and stream.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

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>) -> impl Into<Output<Self::Output>>;
}

pub enum Output<T> {
    Next,
    One(T),
    Many(Vec<T>),
    Done,
    DoneWithOne(T),
    DoneWithMany(Vec<T>),
}

impl<T> Output<T> {
    pub fn is_done(&self) -> bool {
        match self {
            Self::Done | Self::DoneWithOne(_) | Self::DoneWithMany(_) => true,
            _ => false,
        }
    }
}

impl<T> From<Option<T>> for Output<T> {
    fn from(value: Option<T>) -> Self {
        match value {
            None => Self::Next,
            Some(value) => Self::One(value),
        }
    }
}