dencode 0.3.0

Utilities for decoding and encoding frames from readers and writers.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

use dencode::{FramedRead, LinesCodec};
use futures::{executor, io::Cursor, TryStreamExt};

#[test]
fn it_works() {
    let buf = "Hello\nWorld\nError".to_owned();
    let cur = Cursor::new(buf);

    let mut framed = FramedRead::new(cur, LinesCodec {});
    let next = executor::block_on(framed.try_next()).unwrap().unwrap();
    assert_eq!(next, "Hello\n");
    let next = executor::block_on(framed.try_next()).unwrap().unwrap();
    assert_eq!(next, "World\n");

    assert!(executor::block_on(framed.try_next()).is_err());
}