fn try_all<Fut, F>(self, f: F) -> TryAll<Self, Fut, F>
    where
        Self: Sized,
        F: FnMut(Self::Ok) -> Fut,
        Fut: Future<Output = bool>,
    {
        assert_future::<Result<bool, Self::Error>, _>(TryAll::new(self, f))
    }
Attempt to execute a predicate over an asynchronous stream and evaluate if all items
satisfy the predicate. Exits early if an `Err` is encountered or if an `Ok` item is found
that does not satisfy the predicate.

# Examples

```
# futures::executor::block_on(async {
use futures::stream::{self, StreamExt, TryStreamExt};
use std::convert::Infallible;

let number_stream = stream::iter(1..10).map(Ok::<_, Infallible>);
let positive = number_stream.try_all(|i| async move { i > 0 });
assert_eq!(positive.await, Ok(true));

let stream_with_errors = stream::iter([Ok(1), Err("err"), Ok(3)]);
let positive = stream_with_errors.try_all(|i| async move { i > 0 });
assert_eq!(positive.await, Err("err"));
# });
```
futures-util/src/stream/try_stream/mod.rs