pull-paramap
Advanced tools
Comparing version 1.2.1 to 1.2.2
@@ -0,1 +1,2 @@ | ||
var looper = require('looper') | ||
module.exports = function (map, width, inOrder) { | ||
@@ -27,3 +28,3 @@ inOrder = inOrder === undefined ? true : inOrder | ||
function start () { | ||
var start = looper(function () { | ||
started = true | ||
@@ -53,3 +54,3 @@ if(ended) return drain() | ||
}) | ||
} | ||
}) | ||
@@ -56,0 +57,0 @@ return function (_abort, cb) { |
{ | ||
"name": "pull-paramap", | ||
"description": "parallel async map pull-stream", | ||
"version": "1.2.1", | ||
"version": "1.2.2", | ||
"homepage": "https://github.com/dominictarr/pull-paramap", | ||
@@ -20,3 +20,6 @@ "repository": { | ||
"author": "Dominic Tarr <dominic.tarr@gmail.com> (http://dominictarr.com)", | ||
"license": "MIT" | ||
"license": "MIT", | ||
"dependencies": { | ||
"looper": "^4.0.0" | ||
} | ||
} |
@@ -189,1 +189,14 @@ var pull = require('pull-stream') | ||
}) | ||
test('range error', function (t) { | ||
pull( | ||
pull.count(10000), | ||
paraMap(function (d, cb) { | ||
cb(null, d*10000) | ||
}), | ||
pull.drain(null, function (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
8891
260
1
+ Addedlooper@^4.0.0
+ Addedlooper@4.0.0(transitive)