chore: shrink keep lease handler buffer

This commit is contained in:
shuiyisong
2023-06-20 15:02:50 +08:00
parent f1983f9131
commit 8ed834b343

View File

@@ -29,7 +29,7 @@ pub struct KeepLeaseHandler {
impl KeepLeaseHandler {
pub fn new(kv_store: KvStoreRef) -> Self {
let (tx, mut rx) = mpsc::channel(1024);
let (tx, mut rx) = mpsc::channel(128);
common_runtime::spawn_bg(async move {
while let Some(kv) = rx.recv().await {
let mut kvs = vec![kv];