diff --git a/futures/tests/stream_peekable.rs b/futures/tests/stream_peekable.rs new file mode 100644 index 0000000000..b65a0572cb --- /dev/null +++ b/futures/tests/stream_peekable.rs @@ -0,0 +1,13 @@ +use futures::executor::block_on; +use futures::pin_mut; +use futures::stream::{self, Peekable, StreamExt}; + +#[test] +fn peekable() { + block_on(async { + let peekable: Peekable<_> = stream::iter(vec![1u8, 2, 3]).peekable(); + pin_mut!(peekable); + assert_eq!(peekable.as_mut().peek().await, Some(&1u8)); + assert_eq!(peekable.collect::>().await, vec![1, 2, 3]); + }); +}