stream-combinators 0.1.0

Additional stream combinators for [`futures-rs`](https://github.com/alexcrichton/futures-rs/) streams.
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

extern crate futures;
extern crate tokio_core;
extern crate tokio_stdin;
extern crate stream_combinators;

use futures::stream::{once, Stream};
use tokio_core::reactor::Core;
use tokio_stdin::spawn_stdin_stream_unbounded;
use stream_combinators::FilterFoldStream;

fn main() {
    let mut core = Core::new().unwrap();

    // Print stdin line-by-line
    let prog = spawn_stdin_stream_unbounded()
        // Include an extra newline in case the input is missing a trailing newline
        // Note: this will print a spurious blank line in the case the input has
        // a trailing newline; see `examples/fancier_stdin_into_lines.rs`
        // for a way to prevent that situation, if it matters.
        .chain(once(Ok('\n' as u8)))
        // Accumulate bytes into lines
        .filter_fold(vec![], |mut buf, byte| {
            if byte == ('\n' as u8) {
                let s = String::from_utf8(buf).unwrap();
                Ok((vec![], Some(s)))
            } else {
                buf.push(byte);
                Ok((buf, None))
            }
        })
        .for_each(|line| {
            println!("{}", line);
            Ok(())
        });


    core.run(prog).unwrap()
}