join all

Author: dcodesdev

Cargo.lock

@@ -10,3 +10,4 @@ anyhow = "1.0.83"
 clap = { version = "4.5.4", features = ["derive"] }
 dirs-next = "2.0.0"
 indicatif = "0.17.8"
+futures = "0.3.30"

Cargo.toml

@@ -1,3 +1,4 @@
+use futures::future::join_all;
 use indicatif::ProgressBar;
 use ssh2::Session;
 use std::{
@@ -40,13 +41,14 @@ impl Connect {
             handles.push(handle);
         }
 
-        for handle in handles {
-            handle.await??;
-        }
-
-        println!("Done in {:.2?}", start.elapsed());
+        let items = join_all(handles).await;
 
-        Ok(())
+        if items.iter().all(|x| x.is_ok()) {
+            println!("Done in {:.2?}", start.elapsed());
+            Ok(())
+        } else {
+            Err(anyhow::anyhow!("One or more files failed to copy"))
+        }
     }
 
     fn list(&self, dir: &PathBuf) -> anyhow::Result<Vec<PathBuf>> {