feat(ingestion_pipeline): early return if any error encountered (#49)

bosun-ai · Jun 14, 2024 · 1f0cd28 · 1f0cd28
1 parent fa74939
commit 1f0cd28
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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;
         }