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