From dc51de2af1c55c62b0d164c94aa267f30895cbe8 Mon Sep 17 00:00:00 2001 From: Gregory Schier Date: Mon, 5 Jan 2026 15:10:54 -0800 Subject: [PATCH] Bump plugin manager channel sizes to account for more plugins --- src-tauri/yaak-plugins/src/manager.rs | 4 ++-- src-tauri/yaak-plugins/src/server_ws.rs | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src-tauri/yaak-plugins/src/manager.rs b/src-tauri/yaak-plugins/src/manager.rs index a4ac3d84..03cf175e 100644 --- a/src-tauri/yaak-plugins/src/manager.rs +++ b/src-tauri/yaak-plugins/src/manager.rs @@ -57,7 +57,7 @@ pub struct PluginManager { impl PluginManager { pub fn new(app_handle: AppHandle) -> PluginManager { - let (events_tx, mut events_rx) = mpsc::channel(128); + let (events_tx, mut events_rx) = mpsc::channel(2048); let (kill_server_tx, kill_server_rx) = tokio::sync::watch::channel(false); let (client_disconnect_tx, mut client_disconnect_rx) = mpsc::channel(128); @@ -320,7 +320,7 @@ impl PluginManager { } pub async fn subscribe(&self, label: &str) -> (String, mpsc::Receiver) { - let (tx, rx) = mpsc::channel(128); + let (tx, rx) = mpsc::channel(2048); let rx_id = format!("{label}_{}", generate_id()); self.subscribers.lock().await.insert(rx_id.clone(), tx); (rx_id, rx) diff --git a/src-tauri/yaak-plugins/src/server_ws.rs b/src-tauri/yaak-plugins/src/server_ws.rs index f8130232..0d28eddf 100644 --- a/src-tauri/yaak-plugins/src/server_ws.rs +++ b/src-tauri/yaak-plugins/src/server_ws.rs @@ -37,7 +37,7 @@ impl PluginRuntimeServerWebsocket { } async fn accept_connection(&self, stream: TcpStream) { - let (to_plugin_tx, mut to_plugin_rx) = mpsc::channel::(128); + let (to_plugin_tx, mut to_plugin_rx) = mpsc::channel::(2048); let mut app_to_plugin_events_tx = self.app_to_plugin_events_tx.lock().await; *app_to_plugin_events_tx = Some(to_plugin_tx);