|
|
@ -10,7 +10,7 @@ use crate::task::{Context, Poll};
|
|
|
|
pin_project! {
|
|
|
|
pin_project! {
|
|
|
|
#[doc(hidden)]
|
|
|
|
#[doc(hidden)]
|
|
|
|
#[allow(missing_debug_implementations)]
|
|
|
|
#[allow(missing_debug_implementations)]
|
|
|
|
pub struct TryForEeachFuture<S, F, T, R> {
|
|
|
|
pub struct TryForEachFuture<S, F, T, R> {
|
|
|
|
#[pin]
|
|
|
|
#[pin]
|
|
|
|
stream: S,
|
|
|
|
stream: S,
|
|
|
|
f: F,
|
|
|
|
f: F,
|
|
|
@ -19,9 +19,9 @@ pin_project! {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
impl<S, F, T, R> TryForEeachFuture<S, F, T, R> {
|
|
|
|
impl<S, F, T, R> TryForEachFuture<S, F, T, R> {
|
|
|
|
pub(crate) fn new(stream: S, f: F) -> Self {
|
|
|
|
pub(crate) fn new(stream: S, f: F) -> Self {
|
|
|
|
TryForEeachFuture {
|
|
|
|
TryForEachFuture {
|
|
|
|
stream,
|
|
|
|
stream,
|
|
|
|
f,
|
|
|
|
f,
|
|
|
|
__from: PhantomData,
|
|
|
|
__from: PhantomData,
|
|
|
@ -30,7 +30,7 @@ impl<S, F, T, R> TryForEeachFuture<S, F, T, R> {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
impl<S, F, E> Future for TryForEeachFuture<S, F, S::Item, E>
|
|
|
|
impl<S, F, E> Future for TryForEachFuture<S, F, S::Item, E>
|
|
|
|
where
|
|
|
|
where
|
|
|
|
S: Stream,
|
|
|
|
S: Stream,
|
|
|
|
S::Item: std::fmt::Debug,
|
|
|
|
S::Item: std::fmt::Debug,
|
|
|
|