event-stream
Advanced tools
Comparing version 3.2.2 to 3.3.0
@@ -34,2 +34,5 @@ //filter will reemit the data if cb(err,pass) pass is truthy | ||
var toMerge = [].slice.call(arguments) | ||
if (toMerge.length === 1 && (toMerge[0] instanceof Array)) { | ||
toMerge = toMerge[0] //handle array as arguments object | ||
} | ||
var stream = new Stream() | ||
@@ -36,0 +39,0 @@ stream.setMaxListeners(0) // allow adding more than 11 streams |
{ | ||
"name": "event-stream", | ||
"version": "3.2.2", | ||
"version": "3.3.0", | ||
"description": "construct pipes of streams of events", | ||
@@ -5,0 +5,0 @@ "homepage": "http://github.com/dominictarr/event-stream", |
@@ -11,2 +11,3 @@ var es = require('../') | ||
var r2 = es.readArray(odd) | ||
var endCount = 0 | ||
@@ -16,8 +17,15 @@ var writer = es.writeArray(function (err, array){ | ||
it(array.sort()).deepEqual(even.concat(odd).sort()) | ||
t.done() | ||
if (++endCount === 2) t.done() | ||
}) | ||
var writer2 = es.writeArray(function (err, array){ | ||
if(err) throw err //unpossible | ||
it(array.sort()).deepEqual(even.concat(odd).sort()) | ||
if (++endCount === 2) t.done() | ||
}) | ||
es.merge(r1, r2).pipe(writer) | ||
es.merge([r1, r2]).pipe(writer2) | ||
} | ||
require('./helper')(module) |
Sorry, the diff of this file is not supported yet
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
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
44333
1165
309