From df22d87d098397149e33a61b3cc676de0ad97c0b Mon Sep 17 00:00:00 2001
From: Oleg Nosov <olegnosov1@gmail.com>
Date: Fri, 12 Jun 2020 18:18:40 +0300
Subject: [PATCH] Removed unnecessary links + hotfix

---
 src/stream/stream/flatten.rs | 2 +-
 tests/stream.rs              | 2 --
 2 files changed, 1 insertion(+), 3 deletions(-)

diff --git a/src/stream/stream/flatten.rs b/src/stream/stream/flatten.rs
index 7a767e1e..35236038 100644
--- a/src/stream/stream/flatten.rs
+++ b/src/stream/stream/flatten.rs
@@ -53,7 +53,7 @@ where
         loop {
             if let Some(inner) = this.inner_stream.as_mut().as_pin_mut() {
                 match futures_core::ready!(inner.poll_next(cx)) {
-                    item @ Some(_) => return Poll::Ready(next_item),
+                    item @ Some(_) => return Poll::Ready(item),
                     None => this.inner_stream.set(None),
                 }
             }
diff --git a/tests/stream.rs b/tests/stream.rs
index 47ff228d..3a192339 100644
--- a/tests/stream.rs
+++ b/tests/stream.rs
@@ -154,7 +154,6 @@ impl Stream for Interchanger {
     }
 }
 
-// https://github.com/async-rs/async-std/pull/701
 #[test]
 fn flat_map_doesnt_poll_completed_inner_stream() {
     task::block_on(async {
@@ -169,7 +168,6 @@ fn flat_map_doesnt_poll_completed_inner_stream() {
     });
 }
 
-// https://github.com/async-rs/async-std/pull/701
 #[test]
 fn flatten_doesnt_poll_completed_inner_stream() {
     task::block_on(async {