diff options
author | 2019-06-06 14:05:16 -0700 | |
---|---|---|
committer | 2019-06-06 14:08:29 -0700 | |
commit | 5759211ff81c3601015a0c0dad96f9366965446c (patch) | |
tree | f35a46ed391a2dedf99e0e4ff5181a559ffdf50c /tests/test_reader.rs | |
parent | 60aceba2bb1dfacbca395832d2f36eabd517fcb1 (diff) | |
parent | d43e283e5ed520e54df2428f2cf9a7c13c79ff49 (diff) | |
download | bytes-5759211ff81c3601015a0c0dad96f9366965446c.tar.gz bytes-5759211ff81c3601015a0c0dad96f9366965446c.tar.zst bytes-5759211ff81c3601015a0c0dad96f9366965446c.zip |
Merge branch 'v0.4.x' into uplift-0.4-commits
Diffstat (limited to 'tests/test_reader.rs')
-rw-r--r-- | tests/test_reader.rs | 28 |
1 files changed, 28 insertions, 0 deletions
diff --git a/tests/test_reader.rs b/tests/test_reader.rs new file mode 100644 index 0000000..7103f35 --- /dev/null +++ b/tests/test_reader.rs @@ -0,0 +1,28 @@ +extern crate bytes; + +use std::io::{BufRead, Cursor, Read}; + +use bytes::Buf; + +#[test] +fn read() { + let buf1 = Cursor::new(b"hello "); + let buf2 = Cursor::new(b"world"); + let buf = Buf::chain(buf1, buf2); // Disambiguate with Read::chain + let mut buffer = Vec::new(); + buf.reader().read_to_end(&mut buffer).unwrap(); + assert_eq!(b"hello world", &buffer[..]); +} + +#[test] +fn buf_read() { + let buf1 = Cursor::new(b"hell"); + let buf2 = Cursor::new(b"o\nworld"); + let mut reader = Buf::chain(buf1, buf2).reader(); + let mut line = String::new(); + reader.read_line(&mut line).unwrap(); + assert_eq!("hello\n", &line); + line.clear(); + reader.read_line(&mut line).unwrap(); + assert_eq!("world", &line); +} |