Comparing version 1.1.7 to 1.1.8
var pull = require('pull-core') | ||
var noop = function () {} | ||
@@ -24,3 +25,3 @@ function all(ary, abort, cb) { | ||
else if(!streams.length) | ||
cb(true) | ||
cb(true) | ||
else if(!streams[0]) | ||
@@ -31,3 +32,3 @@ streams.shift(), next() | ||
if(err) { | ||
streams.shift() | ||
streams.shift() | ||
if(err !== true) { | ||
@@ -37,3 +38,3 @@ abort = err | ||
while(streams.length) | ||
streams.shift()(err, function () {}) | ||
(streams.shift() || noop)(err, noop) | ||
cb(err) | ||
@@ -46,4 +47,4 @@ } | ||
}) | ||
})() | ||
})() | ||
} | ||
}) |
{ | ||
"name": "pull-cat", | ||
"description": "concatenate pull-streams", | ||
"version": "1.1.7", | ||
"version": "1.1.8", | ||
"homepage": "https://github.com/dominictarr/pull-cat", | ||
@@ -6,0 +6,0 @@ "repository": { |
@@ -114,1 +114,14 @@ | ||
}) | ||
test('error + undefined', function (t) { | ||
var err = new Error('test error') | ||
pull( | ||
cat([pull.values([1,2,3]), function (_, cb) { | ||
cb(err) | ||
}, undefined]), | ||
pull.collect(function (_err) { | ||
t.equal(_err, err) | ||
t.end() | ||
}) | ||
) | ||
}) |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
5464
150