--- a/cmds/fleet/src/cmds/build_systems.rs +++ b/cmds/fleet/src/cmds/build_systems.rs @@ -61,7 +61,7 @@ impl BuildSystems { pub async fn run(self, config: &Config, opts: &FleetOpts) -> Result<()> { let hosts = opts.filter_skipped(config.list_hosts()?)?; - let mut tasks = FuturesUnordered::new(); + let tasks = FuturesUnordered::new(); let build_attr = self.build_attr.clone(); for host in hosts { let config = config.clone(); @@ -89,7 +89,7 @@ .instrument(span), ); } - for _task in tasks.next().await {} + tasks.collect::>().await; Ok(()) } } @@ -171,7 +171,7 @@ .instrument(span), ); } - for _task in tasks.next().await {} + tasks.collect::>().await; Ok(()) } }