Merge pull request #4490 from anoma/grarco/unordered-buffer

mergify[bot] · web-flow · commit 3f34d31afb01 · 2025-03-24T20:52:40.000Z
Unordered buffer for fetched masp txs
diff --git a/.changelog/unreleased/improvements/4490-unordered-buffer.md b/.changelog/unreleased/improvements/4490-unordered-buffer.md
@@ -0,0 +1,2 @@
+- Restored the old unordered buffer for fetched shielded transactions.
+  ([\#4490](https://github.com/anoma/namada/pull/4490))
diff --git a/crates/sdk/src/masp/utilities.rs b/crates/sdk/src/masp/utilities.rs
@@ -528,8 +528,8 @@ impl MaspClient for IndexerMaspClient {
             }
         }
 
-        let mut stream_of_fetches =
-            stream::iter(fetches).buffered(self.shared.max_concurrent_fetches);
+        let mut stream_of_fetches = stream::iter(fetches)
+            .buffer_unordered(self.shared.max_concurrent_fetches);
         let mut txs = vec![];
 
         while let Some(result) = stream_of_fetches.next().await {

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,2 @@`
	`1`	`+- Restored the old unordered buffer for fetched shielded transactions.`
	`2`	`+ ([\#4490](https://github.com/anoma/namada/pull/4490))`
Original file line number	Diff line number	Diff line change
`@@ -528,8 +528,8 @@ impl MaspClient for IndexerMaspClient {`
`528`	`528`	`}`
`529`	`529`	`}`
`530`	`530`
`531`		`- let mut stream_of_fetches =`
`532`		`- stream::iter(fetches).buffered(self.shared.max_concurrent_fetches);`
	`531`	`+ let mut stream_of_fetches = stream::iter(fetches)`
	`532`	`+ .buffer_unordered(self.shared.max_concurrent_fetches);`
`533`	`533`	`let mut txs = vec![];`
`534`	`534`
`535`	`535`	`while let Some(result) = stream_of_fetches.next().await {`