Merge pull request #33 from petrosagg/bigger-channels

tokio-postgres: increase size of client<->connection channels

Author: petrosagg

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)

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))?;