pull-cat - npm Package Compare versions

Comparing version 1.1.5 to 1.1.7

index.js

@@ -5,2 +5,3 @@ var pull = require('pull-core')
   var n = ary.length
+  if(!n) return cb(abort)
   ary.forEach(function (f) {
@@ -7,0 +8,0 @@ if(f) f(abort, next)

package.json

 {
   "name": "pull-cat",
   "description": "concatenate pull-streams",
-  "version": "1.1.5",
+  "version": "1.1.7",
   "homepage": "https://github.com/dominictarr/pull-cat",
@@ -15,3 +15,5 @@ "repository": {
     "pull-stream": "~2.20",
-    "tape": "~1.0"
+    "tape": "~1.0",
+    "pull-pushable": "~1.1.4",
+    "pull-abortable": "~4.1.0"
   },
@@ -18,0 +20,0 @@ "scripts": {

test/index.js

@@ -6,3 +6,4 @@
 var test = require('tape')
-
+var Pushable = require('pull-pushable')
+var Abortable = require('pull-abortable')
 test('cat', function (t) {
@@ -78,1 +79,37 @@
 })
+
+test('abort stalled', function (t) {
+  var err = new Error('intentional'), n = 2
+  var abortable = Abortable()
+  var pushable = Pushable(function (_err) {
+    t.equal(_err, err)
+    next()
+  })
+
+  pushable.push(4)
+
+  pull(
+    cat([pull.values([1,2,3]), undefined, pushable]),
+    abortable,
+    pull.drain(function (item) {
+      if(item == 4)
+        process.nextTick(function () {
+          abortable.abort(err)
+        })
+    }, function (err) {
+      next()
+    })
+  )
+
+  function next () {
+    if(--n) return
+    t.end()
+  }
+})
+
+test('abort empty', function (t) {
+  cat([])(true, function (end) {
+    t.equal(end, 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

5186

increased by18.7%

Lines of code

137

increased by33.01%

Worsened metrics

Dev dependency count

4

increased by100%

No dependency changes