impl FusedStream for Receiver (Fixes #3) (#30)

smol-rs · Jan 11, 2021 · 21affd9 · 21affd9
1 parent 79cbf4e
commit 21affd9
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/src/lib.rs b/src/lib.rs
@@ -793,6 +793,12 @@ impl<T> Stream for Receiver<T> {
     }
 }
 
+impl<T> futures_core::stream::FusedStream for Receiver<T> {
+    fn is_terminated(&self) -> bool {
+        self.channel.queue.is_closed() && self.channel.queue.is_empty()
+    }
+}
+
 /// An error returned from [`Sender::send()`].
 ///
 /// Received because the channel is closed.