Merge pull request #7 from jean-airoldie/fused_stream

Added FusedStream impl for Unordered
udoprog · Jul 2, 2020 · 93feb80 · 93feb80
2 parents 574c030 + 19e3a0c
commit 93feb80
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/src/lib.rs b/src/lib.rs
@@ -162,7 +162,7 @@ use self::pin_slab::PinSlab;
 use self::wake_set::{SharedWakeSet, WakeSet};
 use self::waker::SharedWaker;
 #[cfg(feature = "futures-rs")]
-use futures_core::Stream;
+use futures_core::{FusedStream, Stream};
 use std::{
     future::Future,
     iter, marker, mem,
@@ -905,6 +905,12 @@ cfg_futures_rs! {
         }
     }
 
+    impl<T, S> FusedStream for Unordered<T, S> where S: Sentinel, Self: PollNext, {
+        fn is_terminated(&self) -> bool {
+            self.is_empty()
+        }
+    }
+
     impl<T> PollNext for StreamsUnordered<T>
     where
         T: Stream,