From 1a52ef2eaaf80e104b921455b7a126853fb1a884 Mon Sep 17 00:00:00 2001
From: Petros Angelatos <petrosagg@gmail.com>
Date: Thu, 11 Dec 2025 17:50:15 +0200
Subject: [PATCH] tokio-postgres: increase size of client<->connection channels

Signed-off-by: Petros Angelatos <petrosagg@gmail.com>
---
 tokio-postgres/src/client.rs  | 2 +-
 tokio-postgres/src/copy_in.rs | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/tokio-postgres/src/client.rs b/tokio-postgres/src/client.rs
index 8fe8090a3..8c3c04fc8 100644
--- a/tokio-postgres/src/client.rs
+++ b/tokio-postgres/src/client.rs
@@ -113,7 +113,7 @@ pub struct InnerClient {
 
 impl InnerClient {
     pub fn send(&self, messages: RequestMessages) -> Result<Responses, Error> {
-        let (sender, receiver) = mpsc::channel(1);
+        let (sender, receiver) = mpsc::channel(1024);
         let request = Request { messages, sender };
         self.sender
             .unbounded_send(request)
diff --git a/tokio-postgres/src/copy_in.rs b/tokio-postgres/src/copy_in.rs
index 8cdb817ac..4e786e564 100644
--- a/tokio-postgres/src/copy_in.rs
+++ b/tokio-postgres/src/copy_in.rs
@@ -192,7 +192,7 @@ async fn start<T>(client: &InnerClient, buf: Bytes, simple: bool) -> Result<Copy
 where
     T: Buf + 'static + Send,
 {
-    let (mut sender, receiver) = mpsc::channel(1);
+    let (mut sender, receiver) = mpsc::channel(1024);
     let receiver = CopyInReceiver::new(receiver);
     let mut responses = client.send(RequestMessages::CopyIn(receiver))?;