From 2aeaa32c683f0f98a285c77b393b0f15ac37b6ab Mon Sep 17 00:00:00 2001 From: Jiahao XU Date: Sat, 22 Jun 2024 05:40:40 +0000 Subject: [PATCH] Apply cargo fmt --- crates/binstalk-fetchers/src/futures_resolver.rs | 6 +++--- crates/binstalk/src/ops/resolve.rs | 8 +++++--- 2 files changed, 8 insertions(+), 6 deletions(-) diff --git a/crates/binstalk-fetchers/src/futures_resolver.rs b/crates/binstalk-fetchers/src/futures_resolver.rs index fb0adda8..d3a651ca 100644 --- a/crates/binstalk-fetchers/src/futures_resolver.rs +++ b/crates/binstalk-fetchers/src/futures_resolver.rs @@ -1,7 +1,7 @@ -use std::{future::Future, pin::Pin, fmt::Debug}; +use std::{fmt::Debug, future::Future, pin::Pin}; -use tracing::warn; use tokio::sync::mpsc; +use tracing::warn; /// Given multiple futures with output = `Result, E>`, /// returns the the first one that returns either `Err(_)` or @@ -73,7 +73,7 @@ impl FuturesResolver { let mut rx = self.rx; drop(self.tx); - async move { + async move { while let Some(res) = rx.recv().await { match res { Ok(ret) => return Some(ret), diff --git a/crates/binstalk/src/ops/resolve.rs b/crates/binstalk/src/ops/resolve.rs index e6c5baa8..b8e02374 100644 --- a/crates/binstalk/src/ops/resolve.rs +++ b/crates/binstalk/src/ops/resolve.rs @@ -139,8 +139,7 @@ async fn resolve_inner( target_data, opts.signature_policy, ); - filter_fetcher_by_name_predicate(fetcher.fetcher_name()) - .then_some(fetcher) + filter_fetcher_by_name_predicate(fetcher.fetcher_name()).then_some(fetcher) }), ) }; @@ -167,7 +166,10 @@ async fn resolve_inner( for fetcher in handles { fetcher.clone().report_to_upstream(); - match AutoAbortJoinHandle::new(fetcher.clone().find()).flattened_join().await { + match AutoAbortJoinHandle::new(fetcher.clone().find()) + .flattened_join() + .await + { Ok(true) => { // Generate temporary binary path let bin_path = opts.temp_dir.join(format!(