From 1f0cd28ce4c02a39dbab7dd3c3f789798644daa3 Mon Sep 17 00:00:00 2001 From: Timon Vonk Date: Fri, 14 Jun 2024 16:59:53 +0200 Subject: [PATCH] feat(ingestion_pipeline): early return if any error encountered (#49) --- swiftide/src/ingestion/ingestion_pipeline.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/swiftide/src/ingestion/ingestion_pipeline.rs b/swiftide/src/ingestion/ingestion_pipeline.rs index 7e1639c3..c1ce2e3e 100644 --- a/swiftide/src/ingestion/ingestion_pipeline.rs +++ b/swiftide/src/ingestion/ingestion_pipeline.rs @@ -268,7 +268,7 @@ impl IngestionPipeline { futures_util::future::try_join_all(setup_futures).await?; let mut total_nodes = 0; - while self.stream.next().await.is_some() { + while self.stream.try_next().await?.is_some() { total_nodes += 1; }