fix: Correctly use concurrency config option (#385)

near · Dec 1, 2023 · a06bcec · a06bcec
1 parent d8ee669
commit a06bcec
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/indexer/src/main.rs b/indexer/src/main.rs
@@ -256,7 +256,7 @@ async fn main() -> anyhow::Result<()> {
                 receipts_cache_arc.clone(),
             )
         })
-        .buffer_unordered(1usize);
+        .buffer_unordered(usize::from(opts.concurrency.get()));
 
     while let Some(handle_message) = handlers.next().await {
         if let Err(e) = handle_message {