stream-combiner2
Advanced tools
Comparing version 1.0.1 to 1.0.2
@@ -70,4 +70,4 @@ var duplexer = require('duplexer2') | ||
var dup = duplexer(input, output) | ||
tr.on('error', function (err) { dup.emit('error') }); | ||
tr.on('error', function (err) { dup.emit('error', err) }); | ||
return dup; | ||
} |
{ | ||
"name": "stream-combiner2", | ||
"version": "1.0.1", | ||
"version": "1.0.2", | ||
"homepage": "https://github.com/substack/stream-combiner2", | ||
@@ -5,0 +5,0 @@ "repository": { |
@@ -6,2 +6,20 @@ var es = require('event-stream') | ||
test('re-emit error object for old streams', function (test) { | ||
test.plan(1) | ||
var expectedErr = new Error('asplode') | ||
var pipe = combine( | ||
es.through(function(data) { | ||
return this.emit('error', expectedErr) | ||
}) | ||
) | ||
pipe.on('error', function (err) { | ||
test.equal(err, expectedErr) | ||
}) | ||
pipe.write('pow') | ||
}) | ||
test('do not duplicate errors', function (test) { | ||
@@ -8,0 +26,0 @@ |
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
6519
137