blob: b65a0572cb8486d314d58c797c4a56cbbcf3f396 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
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::<Vec<u8>>().await, vec![1, 2, 3]);
});
}
|