From 34cf3039647c7c1f7046f581bba1668f0edf7c4a Mon Sep 17 00:00:00 2001 From: 17ms <79069176+17ms@users.noreply.github.com> Date: Sun, 16 Apr 2023 01:15:18 +0300 Subject: [PATCH] increased mpsc buffer sizes, hopefully resolves #3 --- tests/sockets_integration.rs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/tests/sockets_integration.rs b/tests/sockets_integration.rs index 21d5117..11d7d20 100644 --- a/tests/sockets_integration.rs +++ b/tests/sockets_integration.rs @@ -33,10 +33,10 @@ fn filesync_signals() { let output_path = PathBuf::from("./tests/output/"); let server_addr = SocketAddr::from(([127, 0, 0, 1], 9191)); - let (kill_server_tx, server_rx) = mpsc::channel::(2); - let (server_tx, mut local_server_rx) = mpsc::channel::(2); - let (local_client_tx, client_rx) = mpsc::channel::(2); - let (client_tx, mut local_client_rx) = mpsc::channel::(2); + let (kill_server_tx, server_rx) = mpsc::channel::(10); + let (server_tx, mut local_server_rx) = mpsc::channel::(10); + let (local_client_tx, client_rx) = mpsc::channel::(10); + let (client_tx, mut local_client_rx) = mpsc::channel::(10); let server_handle = thread::spawn(move || { let listener = Listener::new(server_addr, "xyz", 8192usize);