44 lines
902 B
Rust
44 lines
902 B
Rust
//! TryStreamTools for futures::TryStream
|
|
#![allow(clippy::type_complexity)]
|
|
|
|
use futures::{TryStream, TryStreamExt, future, future::Ready, stream::TryTakeWhile};
|
|
|
|
use crate::Result;
|
|
|
|
/// TryStreamTools
|
|
pub trait TryTools<T, E, S>
|
|
where
|
|
S: TryStream<Ok = T, Error = E, Item = Result<T, E>> + ?Sized,
|
|
Self: TryStream + Sized,
|
|
{
|
|
fn try_take(
|
|
self,
|
|
n: usize,
|
|
) -> TryTakeWhile<
|
|
Self,
|
|
Ready<Result<bool, S::Error>>,
|
|
impl FnMut(&S::Ok) -> Ready<Result<bool, S::Error>>,
|
|
>;
|
|
}
|
|
|
|
impl<T, E, S> TryTools<T, E, S> for S
|
|
where
|
|
S: TryStream<Ok = T, Error = E, Item = Result<T, E>> + ?Sized,
|
|
Self: TryStream + Sized,
|
|
{
|
|
#[inline]
|
|
fn try_take(
|
|
self,
|
|
mut n: usize,
|
|
) -> TryTakeWhile<
|
|
Self,
|
|
Ready<Result<bool, S::Error>>,
|
|
impl FnMut(&S::Ok) -> Ready<Result<bool, S::Error>>,
|
|
> {
|
|
self.try_take_while(move |_| {
|
|
let res = future::ok(n > 0);
|
|
n = n.saturating_sub(1);
|
|
res
|
|
})
|
|
}
|
|
}
|