increase buffer size in common

Author: paulgb

common/src/typed_socket/client.rs

@@ -125,9 +125,9 @@ async fn new_client<T: ChannelMessage>(
     mut socket: Socket,
     remote_handshake: Handshake,
 ) -> Result<TypedSocket<T>, PlaneClientError> {
-    let (send_to_client, recv_to_client) = tokio::sync::mpsc::channel::<T::Reply>(100);
+    let (send_to_client, recv_to_client) = tokio::sync::mpsc::channel::<T::Reply>(1024);
     let (send_from_client, mut recv_from_client) =
-        tokio::sync::mpsc::channel::<SocketAction<T>>(100);
+        tokio::sync::mpsc::channel::<SocketAction<T>>(1024);
 
     tokio::spawn(async move {
         loop {

common/src/typed_socket/server.rs

@@ -109,8 +109,8 @@ pub async fn new_server<T: ChannelMessage>(
 
     local_handshake.check_compat(&remote_handshake);
 
-    let (outgoing_message_sender, outgoing_message_receiver) = tokio::sync::mpsc::channel(100);
-    let (incoming_message_sender, incoming_message_receiver) = tokio::sync::mpsc::channel(100);
+    let (outgoing_message_sender, outgoing_message_receiver) = tokio::sync::mpsc::channel(1024);
+    let (incoming_message_sender, incoming_message_receiver) = tokio::sync::mpsc::channel(1024);
     tokio::spawn(async move {
         handle_messages(outgoing_message_receiver, incoming_message_sender, ws).await;
     });