fastparallel
Advanced tools
Comparing version 1.1.0 to 1.1.1
{ | ||
"name": "fastparallel", | ||
"version": "1.1.0", | ||
"version": "1.1.1", | ||
"description": "Zero-overhead async.parallel", | ||
@@ -5,0 +5,0 @@ "main": "parallel.js", |
@@ -21,7 +21,12 @@ var xtend = require('xtend') | ||
holder._count = toCall.length | ||
holder._callback = done | ||
if (toCall.length === 0) { | ||
done() | ||
released(last) | ||
} else { | ||
holder._count = toCall.length | ||
holder._callback = done | ||
for (i = 0; i < toCall.length; i++) { | ||
toCall[i].call(that, arg, holder.release) | ||
for (i = 0; i < toCall.length; i++) { | ||
toCall[i].call(that, arg, holder.release) | ||
} | ||
} | ||
@@ -28,0 +33,0 @@ } |
@@ -15,2 +15,4 @@ # fastparallel | ||
[![js-standard-style](https://raw.githubusercontent.com/feross/standard/master/badge.png)](https://github.com/feross/standard) | ||
## Example | ||
@@ -17,0 +19,0 @@ |
17
test.js
@@ -122,1 +122,18 @@ var test = require('tape') | ||
}) | ||
test('should call done and released if an empty is passed', function (t) { | ||
t.plan(2) | ||
var instance = parallel({ | ||
released: released | ||
}) | ||
var obj = {} | ||
instance(obj, [], 42, function done () { | ||
t.pass() | ||
}) | ||
function released() { | ||
t.pass() | ||
} | ||
}) |
9638
260
60