Update src/stream/stream/flatten.rs

k-nasa · taiki-e · web-flow · commit b7b5df13aa78 · 2019-10-26T01:42:39.000+09:00
Co-Authored-By: Taiki Endo &lt;te316e89@gmail.com&gt;
diff --git a/src/stream/stream/flatten.rs b/src/stream/stream/flatten.rs
@@ -108,7 +108,7 @@ where
     fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
         let mut this = self.project();
         loop {
-            if let Some(inner) = this.frontiter {
+            if let Some(inner) = this.frontiter.as_mut().as_pin_mut() {
                 if let item @ Some(_) = futures_core::ready!(Pin::new(inner).poll_next(cx)) {
                     return Poll::Ready(item);
                 }

Original file line number	Diff line number	Diff line change
`@@ -108,7 +108,7 @@ where`
`108`	`108`	`fn poll_next(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {`
`109`	`109`	`let mut this = self.project();`
`110`	`110`	`loop {`
`111`		`- if let Some(inner) = this.frontiter {`
	`111`	`+ if let Some(inner) = this.frontiter.as_mut().as_pin_mut() {`
`112`	`112`	`if let item @ Some(_) = futures_core::ready!(Pin::new(inner).poll_next(cx)) {`
`113`	`113`	`return Poll::Ready(item);`
`114`	`114`	`}`