pull-cat - npm Package Compare versions

Comparing version 1.0.3 to 1.1.0

index.js

@@ -23,6 +23,8 @@ var pull = require('pull-stream')
           cb(true)
+      else if(!streams[0])
+        streams.shift(), next()
       else
         streams[0](null, function (err, data) {
           if(err) {
-            streams.shift();
+              streams.shift()
             if(err !== true)
@@ -29,0 +31,0 @@ abort = err

package.json

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

test/index.js

@@ -17,1 +17,27 @@
 })
+
+require('tape')('cat - with empty', function (t) {
+
+  cat([pull.values([1,2,3]), null, pull.values([4,5,6])])
+  .pipe(pull.collect(function (err, ary) {
+    console.log(err, ary)
+    t.notOk(err)
+    t.deepEqual(ary, [1,2,3,4,5,6])
+    t.end()
+  }))
+
+})
+
+require('tape')('cat - with empty stream', function (t) {
+  var ended = false
+  var justEnd = function (err, cb) { ended = true; cb(true) }
+  cat([pull.values([1,2,3]), justEnd, pull.values([4,5,6])])
+  .pipe(pull.collect(function (err, ary) {
+    console.log(err, ary)
+    t.ok(ended)
+    t.notOk(err)
+    t.deepEqual(ary, [1,2,3,4,5,6])
+    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

3637

increased by22.87%

Lines of code

67

increased by52.27%

No dependency changes