summaryrefslogtreecommitdiff
path: root/lib/internal/parallel.js
diff options
context:
space:
mode:
Diffstat (limited to 'lib/internal/parallel.js')
-rw-r--r--lib/internal/parallel.js12
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);
});