From 760e4a4f3b0169a1bff56fb647466cce50ef069b Mon Sep 17 00:00:00 2001 From: Steven Fackler Date: Sun, 23 Dec 2018 15:50:41 -0800 Subject: [PATCH] Guarantee some buffer for messages --- tokio-postgres/src/proto/client.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 {