diff --git a/src/stream/stream/scan.rs b/src/stream/stream/scan.rs index 4846144d8..222022b8f 100644 --- a/src/stream/stream/scan.rs +++ b/src/stream/stream/scan.rs @@ -1,7 +1,8 @@ -use crate::task::{Context, Poll}; - use std::pin::Pin; +use crate::stream::Stream; +use crate::task::{Context, Poll}; + /// A stream to maintain state while polling another stream. #[derive(Debug)] pub struct Scan { @@ -25,7 +26,7 @@ impl Unpin for Scan {} impl futures_core::stream::Stream for Scan where - S: futures_core::stream::Stream, + S: Stream, F: FnMut(&mut St, S::Item) -> Option, { type Item = B;