diff options
| author | Jeff Vander Stoep <jeffv@google.com> | 2024-02-06 08:51:07 +0000 |
|---|---|---|
| committer | Automerger Merge Worker <android-build-automerger-merge-worker@system.gserviceaccount.com> | 2024-02-06 08:51:07 +0000 |
| commit | ec5ce4148e4305e26cac35f17c256dfb061f4080 (patch) | |
| tree | 7d82b51451e1a8a40106414e34385ff76a3f7c3e /tests/stream_close.rs | |
| parent | cf61bbd97b6e6934c14617749aac69c90ce516bd (diff) | |
| parent | ddb59c87394b27e094ff61ba6ec50ea25e2bac61 (diff) | |
| download | tokio-stream-ec5ce4148e4305e26cac35f17c256dfb061f4080.tar.gz | |
Upgrade tokio-stream to 0.1.14 am: ddb59c8739emu-34-2-dev
Original change: https://android-review.googlesource.com/c/platform/external/rust/crates/tokio-stream/+/2950466
Change-Id: Iefc83ade9080a6253372b48389d00b769ce1c442
Signed-off-by: Automerger Merge Worker <android-build-automerger-merge-worker@system.gserviceaccount.com>
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); +} |