multistream
Advanced tools
Comparing version 1.6.0 to 1.6.1
@@ -60,3 +60,3 @@ module.exports = MultiStream | ||
var self = this | ||
var stream = (typeof self._queue === 'function' ? self._queue() : self._queue.shift()) | ||
var stream = (typeof self._queue === 'function' ? toStreams2(self._queue()) : self._queue.shift()) | ||
@@ -63,0 +63,0 @@ if (typeof stream === 'function') stream = toStreams2(stream()) |
{ | ||
"name": "multistream", | ||
"description": "A stream that emits multiple other streams one after another (streams2)", | ||
"version": "1.6.0", | ||
"version": "1.6.1", | ||
"author": "Feross Aboukhadijeh <feross@feross.org> (http://feross.org/)", | ||
@@ -6,0 +6,0 @@ "bugs": { |
@@ -85,1 +85,26 @@ var concat = require('concat-stream') | ||
}) | ||
test('lazy stream via generator (classic)', function (t) { | ||
var count = 0 | ||
var streams = function () { | ||
if (count > 2) { | ||
return null | ||
} | ||
count++ | ||
var s = through() | ||
process.nextTick(function () { | ||
s.write(count.toString()) | ||
s.end() | ||
}) | ||
return s | ||
} | ||
new MultiStream(streams) | ||
.on('error', function (err) { | ||
t.fail(err) | ||
}) | ||
.pipe(concat(function (data) { | ||
t.equal(data.toString(), '123') | ||
t.end() | ||
})) | ||
}) |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
New author
Supply chain riskA new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
32948
182
1