impl FusedStream for Fuse

5 years ago · d55cfb1da8
parent 0e3c47c3bf
commit d55cfb1da8
1 changed files with 6 additions and 0 deletions
--- a/src/stream/stream/fuse.rs
+++ b/src/stream/stream/fuse.rs
@ -31,3 +31,9 @@ impl<S: futures_core::Stream> futures_core::Stream for Fuse<S> {
        }
    }
 }
+
+impl<S: futures_core::Stream> futures_core::stream::FusedStream for Fuse<S> {
+    fn is_terminated(&self) -> bool {
+        self.done
+    }
+}