compose-stream
Advanced tools
Comparing version 0.0.1 to 0.0.2
@@ -5,2 +5,3 @@ 'use strict'; | ||
var through = require('through2'); | ||
var merge = require('merge-stream'); | ||
@@ -25,2 +26,5 @@ var composeStream = function (fn) { | ||
if (stream) { | ||
if (Array.isArray(stream)) { | ||
stream = merge.apply(null, stream); | ||
} | ||
stream.on('error', function (error) { | ||
@@ -27,0 +31,0 @@ output.emit('error', error); |
{ | ||
"name": "compose-stream", | ||
"version": "0.0.1", | ||
"version": "0.0.2", | ||
"description": "Compose a Node stream at runtime with conditional logic.", | ||
@@ -30,5 +30,6 @@ "main": "index.js", | ||
"dependencies": { | ||
"duplexer2": "0.0.2", | ||
"through2": "0.6.5" | ||
"duplexer2": "0.0.2", | ||
"merge-stream": "1.0.0", | ||
"through2": "0.6.5" | ||
} | ||
} |
4177
47
3
+ Addedmerge-stream@1.0.0
+ Addedisarray@1.0.0(transitive)
+ Addedmerge-stream@1.0.0(transitive)
+ Addedprocess-nextick-args@2.0.1(transitive)
+ Addedreadable-stream@2.3.8(transitive)
+ Addedsafe-buffer@5.1.2(transitive)
+ Addedstring_decoder@1.1.1(transitive)
+ Addedutil-deprecate@1.0.2(transitive)