aboutsummaryrefslogtreecommitdiff
path: root/node_modules/duplexify/index.js
diff options
context:
space:
mode:
authorFlorian Dold <florian.dold@gmail.com>2016-11-03 01:33:53 +0100
committerFlorian Dold <florian.dold@gmail.com>2016-11-03 01:33:53 +0100
commitd1291f67551c58168af43698a359cb5ddfd266b0 (patch)
tree55a13ed29fe1915e3f42f1b1b7038dafa2e975a7 /node_modules/duplexify/index.js
parentd0a0695fb5d34996850723f7d4b1b59c3df909c2 (diff)
node_modules
Diffstat (limited to 'node_modules/duplexify/index.js')
-rw-r--r--node_modules/duplexify/index.js3
1 files changed, 2 insertions, 1 deletions
diff --git a/node_modules/duplexify/index.js b/node_modules/duplexify/index.js
index 377eb60ad..a04f124fa 100644
--- a/node_modules/duplexify/index.js
+++ b/node_modules/duplexify/index.js
@@ -158,7 +158,8 @@ Duplexify.prototype._forward = function() {
var data
- while ((data = shift(this._readable2)) !== null) {
+ while (this._drained && (data = shift(this._readable2)) !== null) {
+ if (this.destroyed) continue
this._drained = this.push(data)
}