diff options
Diffstat (limited to 'lib/internal/parallel.js')
-rw-r--r-- | lib/internal/parallel.js | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/lib/internal/parallel.js b/lib/internal/parallel.js index 70993d3..f4e9347 100644 --- a/lib/internal/parallel.js +++ b/lib/internal/parallel.js @@ -1,6 +1,6 @@ import noop from 'lodash/noop'; import isArrayLike from 'lodash/isArrayLike'; -import rest from './rest'; +import slice from './slice'; import wrapAsync from './wrapAsync'; export default function _parallel(eachfn, tasks, callback) { @@ -8,13 +8,13 @@ export default function _parallel(eachfn, tasks, callback) { var results = isArrayLike(tasks) ? [] : {}; eachfn(tasks, function (task, key, callback) { - wrapAsync(task)(rest(function (err, args) { - if (args.length <= 1) { - args = args[0]; + wrapAsync(task)(function (err, result) { + if (arguments.length > 2) { + result = slice(arguments, 1); } - results[key] = args; + results[key] = result; callback(err); - })); + }); }, function (err) { callback(err, results); }); |