From 47198a3c7b91e6489d5f3662a660d136af358fb8 Mon Sep 17 00:00:00 2001 From: Timon Vonk Date: Wed, 11 Sep 2024 18:53:00 +0200 Subject: [PATCH] Flattening streams can be unlimited as the cost is low --- swiftide-indexing/src/pipeline.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/swiftide-indexing/src/pipeline.rs b/swiftide-indexing/src/pipeline.rs index f7dc9c96..11c44b0e 100644 --- a/swiftide-indexing/src/pipeline.rs +++ b/swiftide-indexing/src/pipeline.rs @@ -272,7 +272,7 @@ impl Pipeline { }) .err_into::() .try_buffer_unordered(concurrency) - .try_flatten_unordered(concurrency) + .try_flatten_unordered(None) .boxed() .into(); @@ -316,7 +316,7 @@ impl Pipeline { }) .err_into::() .try_buffer_unordered(self.concurrency) - .try_flatten_unordered(self.concurrency) + .try_flatten_unordered(None) .boxed().into(); } else { self.stream = self