diff --git a/tokio/src/stream/mod.rs b/tokio/src/stream/mod.rs index c6d22f35782..a99dfca3cfd 100644 --- a/tokio/src/stream/mod.rs +++ b/tokio/src/stream/mod.rs @@ -318,6 +318,7 @@ pub trait StreamExt: Stream { fn all(&mut self, f: F) -> AllFuture<'_, Self, F> where Self: Unpin, + F: FnMut(Self::Item) -> bool, { AllFuture::new(self, f) }