pull-cat - npm Package Compare versions

Comparing version 1.1.0 to 1.1.1

index.js

@@ -6,4 +6,6 @@ var pull = require('pull-stream')
   ary.forEach(function (f) {
-    f(abort, next)
+    if(f) f(abort, next)
+    else next()
   })
+
   function next() {
@@ -10,0 +12,0 @@ if(--n) return

package.json

 {
   "name": "pull-cat",
   "description": "concatenate pull-streams",
-  "version": "1.1.0",
+  "version": "1.1.1",
   "homepage": "https://github.com/dominictarr/pull-cat",
@@ -6,0 +6,0 @@ "repository": {

test/index.js

@@ -5,4 +5,5 @@
 var cat = require('../')
+var test = require('tape')
 
-require('tape')('cat', function (t) {
+test('cat', function (t) {
 
@@ -19,3 +20,3 @@ cat([pull.values([1,2,3]), pull.values([4,5,6])])
 
-require('tape')('cat - with empty', function (t) {
+test('cat - with empty', function (t) {
 
@@ -32,3 +33,3 @@ cat([pull.values([1,2,3]), null, pull.values([4,5,6])])
 
-require('tape')('cat - with empty stream', function (t) {
+test('cat - with empty stream', function (t) {
   var ended = false
@@ -44,3 +45,17 @@ var justEnd = function (err, cb) { ended = true; cb(true) }
   }))
+})
 
+
+
+test('abort - with empty', function (t) {
+
+  cat([pull.values([1,2,3]), null, pull.values([4,5,6])])
+  .pipe(function (read) {
+    read(true, function (err) {
+      t.equal(err, true)
+      t.end()
+    })
+  })
+
 })
+

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

3871

increased by6.43%

Lines of code

78

increased by16.42%

No dependency changes