diff options
Diffstat (limited to 'deps/npm/node_modules/mississippi/node_modules/duplexify/index.js')
-rw-r--r-- | deps/npm/node_modules/mississippi/node_modules/duplexify/index.js | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/deps/npm/node_modules/mississippi/node_modules/duplexify/index.js b/deps/npm/node_modules/mississippi/node_modules/duplexify/index.js index 377eb60ad7..a04f124fa9 100644 --- a/deps/npm/node_modules/mississippi/node_modules/duplexify/index.js +++ b/deps/npm/node_modules/mississippi/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) } |