Fix apocas/dockerode#53

apocas · Dec 28, 2014 · 82d3e9c · 82d3e9c
1 parent 9174961
commit 82d3e9c
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/lib/http_duplex.js b/lib/http_duplex.js
@@ -40,5 +40,11 @@ HttpDuplex.prototype._write = function (chunk, encoding, cb) {
 };
 
 HttpDuplex.prototype.end = function (chunk, encoding, cb) {
+  this._output.destroy();
   return this.req.end(chunk, encoding, cb);
 };
+
+HttpDuplex.prototype.destroy = function () {
+  this.req.destroy();
+  this._output.destroy();
+};