From df2cf0136b5979954cea592f605e83fdff71f79b Mon Sep 17 00:00:00 2001 From: John Yang Date: Wed, 23 Oct 2024 18:45:33 -0700 Subject: [PATCH] Slightly increase channel buffer size --- src/lib.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/lib.rs b/src/lib.rs index 8ec9958..62a4aba 100644 --- 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);