diff options
Diffstat (limited to 'tests/stream_close.rs')
-rw-r--r-- | tests/stream_close.rs | 11 |
1 files changed, 11 insertions, 0 deletions
diff --git a/tests/stream_close.rs b/tests/stream_close.rs new file mode 100644 index 0000000..9ddb565 --- /dev/null +++ b/tests/stream_close.rs @@ -0,0 +1,11 @@ +use tokio_stream::{StreamExt, StreamNotifyClose}; + +#[tokio::test] +async fn basic_usage() { + let mut stream = StreamNotifyClose::new(tokio_stream::iter(vec![0, 1])); + + assert_eq!(stream.next().await, Some(Some(0))); + assert_eq!(stream.next().await, Some(Some(1))); + assert_eq!(stream.next().await, Some(None)); + assert_eq!(stream.next().await, None); +} |