series-stream
Advanced tools
Comparing version 1.0.0 to 1.0.1
@@ -23,5 +23,8 @@ var PassThrough = require('stream').PassThrough | ||
PassThrough.prototype.pipe.call(this, dest) | ||
if (!this._current) { | ||
this._next() | ||
} | ||
return dest | ||
} | ||
@@ -31,2 +34,3 @@ | ||
this._queue.push(src) | ||
return this | ||
} | ||
@@ -45,3 +49,3 @@ | ||
if (this._current) return // Only end when all streams have ended | ||
PassThrough.prototype.end.apply(this, arguments) | ||
return PassThrough.prototype.end.apply(this, arguments) | ||
} | ||
@@ -48,0 +52,0 @@ |
{ | ||
"name": "series-stream", | ||
"version": "1.0.0", | ||
"version": "1.0.1", | ||
"description": "Pipe multiple streams into a single stream, ensuring each added stream finishes piping it's data before the next begins.", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
Major refactor
Supply chain riskPackage has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.
Found 1 instance in 1 package
3586
42
0