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;
         }