diff --git a/src/stream/stream/mod.rs b/src/stream/stream/mod.rs index f7905ed..e46ca9e 100644 --- a/src/stream/stream/mod.rs +++ b/src/stream/stream/mod.rs @@ -85,7 +85,7 @@ use nth::NthFuture; use partial_cmp::PartialCmpFuture; use position::PositionFuture; use try_fold::TryFoldFuture; -use try_for_each::TryForEeachFuture; +use try_for_each::TryForEachFuture; pub use chain::Chain; pub use filter::Filter; @@ -1396,12 +1396,12 @@ extension_trait! { fn try_for_each( self, f: F, - ) -> impl Future [TryForEeachFuture] + ) -> impl Future [TryForEachFuture] where Self: Sized, F: FnMut(Self::Item) -> Result<(), E>, { - TryForEeachFuture::new(self, f) + TryForEachFuture::new(self, f) } #[doc = r#" diff --git a/src/stream/stream/try_for_each.rs b/src/stream/stream/try_for_each.rs index 578b854..6b66d2e 100644 --- a/src/stream/stream/try_for_each.rs +++ b/src/stream/stream/try_for_each.rs @@ -10,7 +10,7 @@ use crate::task::{Context, Poll}; pin_project! { #[doc(hidden)] #[allow(missing_debug_implementations)] - pub struct TryForEeachFuture { + pub struct TryForEachFuture { #[pin] stream: S, f: F, @@ -19,9 +19,9 @@ pin_project! { } } -impl TryForEeachFuture { +impl TryForEachFuture { pub(crate) fn new(stream: S, f: F) -> Self { - TryForEeachFuture { + TryForEachFuture { stream, f, __from: PhantomData, @@ -30,7 +30,7 @@ impl TryForEeachFuture { } } -impl Future for TryForEeachFuture +impl Future for TryForEachFuture where S: Stream, S::Item: std::fmt::Debug,