diff --git a/tokio-postgres/src/proto/client.rs b/tokio-postgres/src/proto/client.rs index cf22add6..54d631c2 100644 --- a/tokio-postgres/src/proto/client.rs +++ b/tokio-postgres/src/proto/client.rs @@ -109,7 +109,7 @@ impl Client { pub fn send(&self, request: PendingRequest) -> Result, Error> { let (messages, idle) = request.0?; - let (sender, receiver) = mpsc::channel(0); + let (sender, receiver) = mpsc::channel(1); self.0 .sender .unbounded_send(Request {