indicator 0.4.4

Abstractions for stream aggregation, we call them `Indicator` s.
Documentation 
1
2
3
4
5
6
7
8
9

use indicator::*;

fn main() {
    let mut m = map(|x| x + 1);
    let mut op = (&mut m).then(map(|x| x + 2));
    for x in [1, 2, 3, 4, 5] {
        println!("{:?}", op.next(x));
    }
}