diff --git a/src/stream/stream/fuse.rs b/src/stream/stream/fuse.rs index 35419370..13850c5a 100644 --- a/src/stream/stream/fuse.rs +++ b/src/stream/stream/fuse.rs @@ -31,3 +31,9 @@ impl futures_core::Stream for Fuse { } } } + +impl futures_core::stream::FusedStream for Fuse { + fn is_terminated(&self) -> bool { + self.done + } +}