From 982c843e276a3a2e93c3288d7dc4b9abaf9ba5c0 Mon Sep 17 00:00:00 2001 From: dawn <90008@gaze.systems> Date: Mon, 26 Jan 2026 04:39:22 +0300 Subject: [PATCH] use tcp_nodelay and increase event buffer size --- tapped/src/channel.rs | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/tapped/src/channel.rs b/tapped/src/channel.rs index 5de4cd0..6a9b020 100644 --- a/tapped/src/channel.rs +++ b/tapped/src/channel.rs @@ -84,6 +84,9 @@ impl EventReceiver { let tcp_stream = tokio::net::TcpStream::connect(addr).await .map_err(Error::Io)?; + // Enable TCP_NODELAY to ensure low latency for streaming events + let _ = tcp_stream.set_nodelay(true); + let client = WebSocketClient::::new(Config::default()); let ws_stream = if ws_url.scheme() == "wss" { @@ -119,7 +122,8 @@ impl EventReceiver { let (read, write) = ws_stream.split(); - let (event_tx, event_rx) = mpsc::channel(100); + // Buffer size increased to 2048 to prevent TCP window clamping during brief processing spikes + let (event_tx, event_rx) = mpsc::channel(2048); let (ack_tx, ack_rx) = mpsc::channel(1000); let ack_tx_clone = ack_tx.clone(); -- 2.51.2