Slightly increase channel buffer size

john-z-yang · Oct 24, 2024 · df2cf01 · df2cf01
1 parent a2cb77e
commit df2cf01
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/lib.rs b/src/lib.rs
@@ -207,7 +207,7 @@ macro_rules! processing_strategy {
             let reducer = $reduce;
             let err_reducer = $reduce_err;
 
-            const CHANNEL_BUFF_SIZE: usize = 64;
+            const CHANNEL_BUFF_SIZE: usize = 128;
             let (reduce_sender, reduce_receiver) = tokio::sync::mpsc::channel(CHANNEL_BUFF_SIZE);
             let (commit_sender, commit_receiver) = tokio::sync::mpsc::channel(CHANNEL_BUFF_SIZE);
             let (err_sender, err_receiver) = tokio::sync::mpsc::channel(CHANNEL_BUFF_SIZE);