Implement flush for InternalStream

2013-12-04 22:52:45 -08:00
parent a2667fd1d2
commit 9a6116f56a
1 changed files with 7 additions and 0 deletions
--- a/lib.rs
+++ b/lib.rs
@@ -314,6 +314,13 @@ impl Writer for InternalStream {
            Ssl(ref mut s) => s.write(buf)
        }
    }
+
+    fn flush(&mut self) {
+        match *self {
+            Normal(ref mut s) => s.flush(),
+            Ssl(ref mut s) => s.flush()
+        }
+    }
 }

 struct InnerPostgresConnection {