From fc0f4f3906f4612df08ef04900e97ae289c432ac Mon Sep 17 00:00:00 2001
From: Jiahao XU <30436523+NobodyXu@users.noreply.github.com>
Date: Sat, 22 Jun 2024 23:15:33 +1000
Subject: [PATCH] Update crates/binstalk-fetchers/src/futures_resolver.rs
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Co-authored-by: Félix Saparelli <felix@passcod.name>
Signed-off-by: Jiahao XU <30436523+NobodyXu@users.noreply.github.com>
---
 crates/binstalk-fetchers/src/futures_resolver.rs | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/crates/binstalk-fetchers/src/futures_resolver.rs b/crates/binstalk-fetchers/src/futures_resolver.rs
index d3a651ca..545d3150 100644
--- a/crates/binstalk-fetchers/src/futures_resolver.rs
+++ b/crates/binstalk-fetchers/src/futures_resolver.rs
@@ -74,13 +74,13 @@ impl<T: Send + 'static, E: Send + Debug + 'static> FuturesResolver<T, E> {
         drop(self.tx);
 
         async move {
-            while let Some(res) = rx.recv().await {
-                match res {
-                    Ok(ret) => return Some(ret),
-                    Err(err) => warn!(?err, "Fail to resolve the future"),
-                }
+            loop {
+	            match rx.recv().await {
+	                Some(Ok(ret)) => return Some(ret),
+	                Some(Err(err)) => warn!(?err, "Fail to resolve the future"),
+	                None => return None,
+	            }
             }
-            None
         }
     }
 }