bypass errors from streams

Author: f1nzer

index.js

@@ -64,6 +64,9 @@ function merge2 () {
 
       stream.on('merge2UnpipeEnd', onend)
       stream.on('end', onend)
+      stream.on('error', function (err) {
+        mergedStream.emit('error', err)
+      })
       stream.pipe(mergedStream, { end: false })
       // compatible for old stream
       stream.resume()

test/index.js

@@ -47,6 +47,26 @@ function test (merge2) {
         })
     })
 
+    tman.it('merge2 - error handling', function (done) {
+      const ts = through.obj()
+
+      const mergeStream = merge2(toThrough(ts))
+
+      const expectedError = new Error('error')
+      thunk.delay(100)(function () {
+        ts.destroy(expectedError)
+      })
+
+      mergeStream
+        .on('error', function (error) {
+          assert.strictEqual(error, expectedError)
+          done()
+        })
+        .on('end', function () {
+          throw Error('error expected')
+        })
+    })
+
     tman.it('merge2(TransformStream)', function (done) {
       const result = []
       const ts = through.obj()