diff options
Diffstat (limited to 'tokio/src/stream/iter.rs')
| -rw-r--r-- | tokio/src/stream/iter.rs | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/tokio/src/stream/iter.rs b/tokio/src/stream/iter.rs index 5909b4cf..36eeb561 100644 --- a/tokio/src/stream/iter.rs +++ b/tokio/src/stream/iter.rs @@ -44,7 +44,8 @@ where { type Item = I::Item; - fn poll_next(mut self: Pin<&mut Self>, _: &mut Context<'_>) -> Poll<Option<I::Item>> { + fn poll_next(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<I::Item>> { + ready!(crate::coop::poll_proceed(cx)); Poll::Ready(self.iter.next()) } |