reduplexer - npm Package Compare versions

Comparing version 0.0.1 to 0.0.2

index.js

@@ -51,2 +51,8 @@ /*
 
+  ;[readable, writable, dummyWritable].forEach(function(stream) {
+    stream.on('error', function(err) {
+      that.emit('error', err)
+    })
+  })
+
   this.on('finish', function() {
@@ -53,0 +59,0 @@ writable.end()

package.json

 {
   "name": "reduplexer",
-  "version": "0.0.1",
+  "version": "0.0.2",
   "description": "Another Stream2 duplexer",
@@ -5,0 +5,0 @@ "main": "index.js",

test.js

@@ -76,1 +76,18 @@
 })
+
+test('pass through error events', function(t) {
+  // two because it must listen for both readable and
+  // writable
+  t.plan(2)
+
+  var writable = new stream.PassThrough()
+    , instance
+
+  instance = duplexer(writable, writable)
+
+  instance.on('error', function(err) {
+    t.ok(err, 'an error is emitted')
+  })
+
+  writable.emit('error', new Error('fake!'))
+})

No alert changes

Improved metrics

Total package byte prevSize

267092

9.39%

Lines of code

124

15.89%

No dependency changes