buffer 16 messages in copy-both involved channels

MaterializeInc · Sep 2, 2024 · 23d1615 · 23d1615
1 parent 37f1114
commit 23d1615
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/tokio-postgres/src/client.rs b/tokio-postgres/src/client.rs
@@ -123,9 +123,9 @@ impl InnerClient {
     }
 
     pub fn start_copy_both(&self) -> Result<CopyBothHandles, Error> {
-        let (sender, receiver) = mpsc::channel(1);
-        let (stream_sender, stream_receiver) = mpsc::channel(0);
-        let (sink_sender, sink_receiver) = mpsc::channel(0);
+        let (sender, receiver) = mpsc::channel(16);
+        let (stream_sender, stream_receiver) = mpsc::channel(16);
+        let (sink_sender, sink_receiver) = mpsc::channel(16);
 
         let responses = Responses {
             receiver,