diff --git a/tokio-postgres/src/client.rs b/tokio-postgres/src/client.rs index e1d784607..eab65d30a 100644 --- 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 { - 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,