From f56668d9f60593cfa99d43aa7ae9cd62e2dad214 Mon Sep 17 00:00:00 2001 From: CleverWild Date: Thu, 19 Mar 2026 17:54:31 +0100 Subject: [PATCH] chore: make const for buffer size --- server/crates/arbiter-client/src/lib.rs | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/server/crates/arbiter-client/src/lib.rs b/server/crates/arbiter-client/src/lib.rs index 322a9bb..753c21a 100644 --- a/server/crates/arbiter-client/src/lib.rs +++ b/server/crates/arbiter-client/src/lib.rs @@ -25,6 +25,8 @@ use tokio::sync::{Mutex, mpsc}; use tokio_stream::wrappers::ReceiverStream; use tonic::transport::ClientTlsConfig; +const BUFFER_LENGTH: usize = 16; + #[derive(Debug, thiserror::Error)] pub enum ConnectError { #[error("Could not establish connection")] @@ -112,7 +114,7 @@ impl ArbiterSigner { .await?; let mut client = ArbiterServiceClient::new(channel); - let (tx, rx) = mpsc::channel(16); + let (tx, rx) = mpsc::channel(BUFFER_LENGTH); let response_stream = client.client(ReceiverStream::new(rx)).await?.into_inner(); let mut transport = ClientTransport {