pumpify - npm Package Compare versions

Comparing version 1.1.0 to 1.1.1

index.js

@@ -48,2 +48,3 @@ var pump = require('pump')
 
+    if (this.destroyed) return onclose()
     this.setWritable(w)
@@ -50,0 +51,0 @@ this.setReadable(r)

package.json

 {
   "name": "pumpify",
-  "version": "1.1.0",
+  "version": "1.1.1",
   "description": "Combine an array of streams into a single duplex stream using pump and duplexify",
@@ -5,0 +5,0 @@ "main": "index.js",

test.js

@@ -145,2 +145,20 @@ var tape = require('tape')
   }, 100)
+})
+
+tape('early destroy', function(t) {
+  var a = through()
+  var b = through()
+  var c = through()
+
+  b.destroy = function() {
+    t.ok(true)
+    t.end()
+  }
+
+  var pipeline = pumpify()
+
+  pipeline.destroy()
+  setTimeout(function() {
+    pipeline.setPipeline(a, b, c)
+  }, 100)
 })

No alert changes

Improved metrics

Total package byte prevSize

7071

4.74%

Lines of code

175

9.38%

No dependency changes