diff options
Diffstat (limited to 'tests/io_read_to_string.rs')
-rw-r--r-- | tests/io_read_to_string.rs | 45 |
1 files changed, 45 insertions, 0 deletions
diff --git a/tests/io_read_to_string.rs b/tests/io_read_to_string.rs new file mode 100644 index 0000000..db825af --- /dev/null +++ b/tests/io_read_to_string.rs @@ -0,0 +1,45 @@ +use futures::executor::block_on; +use futures::future::{Future, FutureExt}; +use futures::stream::{self, StreamExt, TryStreamExt}; +use futures::io::{AsyncReadExt, Cursor}; +use futures::task::Poll; +use futures_test::io::AsyncReadTestExt; +use futures_test::task::noop_context; + +#[test] +fn read_to_string() { + let mut c = Cursor::new(&b""[..]); + let mut v = String::new(); + assert_eq!(block_on(c.read_to_string(&mut v)).unwrap(), 0); + assert_eq!(v, ""); + + let mut c = Cursor::new(&b"1"[..]); + let mut v = String::new(); + assert_eq!(block_on(c.read_to_string(&mut v)).unwrap(), 1); + assert_eq!(v, "1"); + + let mut c = Cursor::new(&b"\xff"[..]); + let mut v = String::new(); + assert!(block_on(c.read_to_string(&mut v)).is_err()); +} + +fn run<F: Future + Unpin>(mut f: F) -> F::Output { + let mut cx = noop_context(); + loop { + if let Poll::Ready(x) = f.poll_unpin(&mut cx) { + return x; + } + } +} + +#[test] +fn interleave_pending() { + let mut buf = stream::iter(vec![&b"12"[..], &b"33"[..], &b"3"[..]]) + .map(Ok) + .into_async_read() + .interleave_pending(); + + let mut v = String::new(); + assert_eq!(run(buf.read_to_string(&mut v)).unwrap(), 5); + assert_eq!(v, "12333"); +} |