From 6b4635fd13f5fe91ad6d388c5e66394627ad7ba2 Mon Sep 17 00:00:00 2001
From: Sean McArthur <sean@seanmonstar.com>
Date: Mon, 2 Oct 2017 18:20:05 -0700
Subject: [PATCH] fix(server): fix experimental pipeline flushing

---
 src/proto/io.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/proto/io.rs b/src/proto/io.rs
index ed30173d..0117758a 100644
--- a/src/proto/io.rs
+++ b/src/proto/io.rs
@@ -147,7 +147,7 @@ impl<T: Write> Write for Buffered<T> {
     }
 
     fn flush(&mut self) -> io::Result<()> {
-        if self.flush_pipeline && self.read_buf.is_empty() {
+        if self.flush_pipeline && !self.read_buf.is_empty() {
             Ok(())
         } else if self.write_buf.remaining() == 0 {
             self.io.flush()