diff --git a/lib/connection.js b/lib/connection.js
index 0fb874cf5..6e9f22eab 100644
--- a/lib/connection.js
+++ b/lib/connection.js
@@ -328,6 +328,7 @@ Connection.prototype.end = function() {
   this.writer.add(emptyBuffer);
   this._ending = true;
   this._send(0x58);
+  this.stream.end();
 };
 
 Connection.prototype.close = function(msg, more) {