From d632a0f77edcc597a04b2fd64f8c07072d097cae Mon Sep 17 00:00:00 2001
From: olegnn <olegnosov1@gmail.com>
Date: Sun, 23 Jan 2022 14:57:59 +0300
Subject: [PATCH] Attempting to fix Miri

---
 futures/tests/stream.rs | 13 +++++++------
 1 file changed, 7 insertions(+), 6 deletions(-)

diff --git a/futures/tests/stream.rs b/futures/tests/stream.rs
index 48a86b950e..231b0c1790 100644
--- a/futures/tests/stream.rs
+++ b/futures/tests/stream.rs
@@ -299,13 +299,14 @@ fn flatten_unordered() {
 
     // stream panics
     {
-        let st = once(async { once(async { panic!("Polled") }).boxed() }.boxed()).chain(
-            Interchanger { polled: false, base: 0, wake_immediately: true }
-                .then(|val| async move { val.boxed() }.boxed())
-                .take(10),
-        );
+        let st = once(async { once(Box::pin(async { panic!("Polled") })).left_stream() }.boxed())
+            .chain(
+                Interchanger { polled: false, base: 0, wake_immediately: true }
+                    .then(|val| async move { val.right_stream() }.boxed())
+                    .take(10),
+            );
 
-        let stream = Arc::new(Mutex::new(st.boxed().flat_map_unordered(10, |s| s.map(identity))));
+        let stream = Arc::new(Mutex::new(st.flat_map_unordered(10, |s| s.map(identity))));
 
         std::thread::spawn({
             let stream = stream.clone();