Flattening streams can be unlimited as the cost is low

bosun-ai · Sep 12, 2024 · 47198a3 · 47198a3
1 parent a4b7edc
commit 47198a3
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/swiftide-indexing/src/pipeline.rs b/swiftide-indexing/src/pipeline.rs
@@ -272,7 +272,7 @@ impl Pipeline {
             })
             .err_into::<anyhow::Error>()
             .try_buffer_unordered(concurrency)
-            .try_flatten_unordered(concurrency)
+            .try_flatten_unordered(None)
             .boxed()
             .into();
 
@@ -316,7 +316,7 @@ impl Pipeline {
                 })
                 .err_into::<anyhow::Error>()
                 .try_buffer_unordered(self.concurrency)
-                .try_flatten_unordered(self.concurrency)
+                .try_flatten_unordered(None)
                 .boxed().into();
         } else {
             self.stream = self