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 FuturesResolver { 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 } } }