Fix for rust <1.51

core/src/dealer/mod.rs

@@ -1,7 +1,6 @@
 mod maps;
 mod protocol;
 
-use std::array;
 use std::iter;
 use std::pin::Pin;
 use std::sync::atomic::AtomicBool;
@@ -543,23 +542,23 @@ async fn run<F, Fut>(
     let init_task = |t| Some(TimeoutOnDrop::new(t, Duration::from_secs(3)));
 
     let mut tasks = if let Some((s, r)) = initial_tasks {
-        [init_task(s), init_task(r)]
+        (init_task(s), init_task(r))
     } else {
-        [None, None]
+        (None, None)
     };
 
     while !shared.is_closed() {
         match &mut tasks {
-            [Some(t0), Some(t1)] => {
+            (Some(t0), Some(t1)) => {
                 select! {
                     () = shared.closed() => break,
                     r = t0 => {
                         r.unwrap(); // Whatever has gone wrong (probably panicked), we can't handle it, so let's panic too.
-                        tasks[0] = None;
+                        tasks.0.take();
                     },
                     r = t1 => {
                         r.unwrap();
-                        tasks[1] = None;
+                        tasks.1.take();
                     }
                 }
             }
@@ -572,7 +571,7 @@ async fn run<F, Fut>(
                 };
 
                 match connect(&url, proxy.as_ref(), &shared).await {
-                    Ok((s, r)) => tasks = [init_task(s), init_task(r)],
+                    Ok((s, r)) => tasks = (init_task(s), init_task(r)),
                     Err(e) => {
                         warn!("Error while connecting: {}", e);
                     }
@@ -581,7 +580,7 @@ async fn run<F, Fut>(
         }
     }
 
-    let tasks = array::IntoIter::new(tasks).flatten();
+    let tasks = tasks.0.into_iter().chain(tasks.1);
 
     let _ = join_all(tasks).await;
 }