We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f466e61 commit 1a97540Copy full SHA for 1a97540
futures-util/src/future/shared.rs
@@ -1,5 +1,5 @@
1
use crate::task::local_waker_ref_from_nonlocal;
2
-use futures_core::future::Future;
+use futures_core::future::{FusedFuture, Future};
3
use futures_core::task::{LocalWaker, Poll, Wake, Waker};
4
use slab::Slab;
5
use std::cell::UnsafeCell;
@@ -174,6 +174,12 @@ where
174
}
175
176
177
+impl<Fut: Future> FusedFuture for Shared<Fut> {
178
+ fn is_terminated(&self) -> bool {
179
+ self.inner.is_none()
180
+ }
181
+}
182
+
183
impl<Fut: Future> Future for Shared<Fut>
184
where
185
Fut::Output: Clone,
0 commit comments