Guarantee some buffer for messages

2018-12-23 15:50:41 -08:00 · 2018-12-23 15:50:41 -08:00 · 760e4a4f3b
commit 760e4a4f3b
parent a1fc412f9e
1 changed files with 1 additions and 1 deletions
--- 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<mpsc::Receiver<Message>, Error> {
        let (messages, idle) = request.0?;
-        let (sender, receiver) = mpsc::channel(0);
+        let (sender, receiver) = mpsc::channel(1);
        self.0
            .sender
            .unbounded_send(Request {