(eachfn, tasks, callback)
| 711 | }; |
| 712 | |
| 713 | function _parallel(eachfn, tasks, callback) { |
| 714 | callback = callback || noop; |
| 715 | var results = _isArrayLike(tasks) ? [] : {}; |
| 716 | |
| 717 | eachfn(tasks, function (task, key, callback) { |
| 718 | task(_restParam(function (err, args) { |
| 719 | if (args.length <= 1) { |
| 720 | args = args[0]; |
| 721 | } |
| 722 | results[key] = args; |
| 723 | callback(err); |
| 724 | })); |
| 725 | }, function (err) { |
| 726 | callback(err, results); |
| 727 | }); |
| 728 | } |
| 729 | |
| 730 | async.parallel = function (tasks, callback) { |
| 731 | _parallel(async.eachOf, tasks, callback); |
no test coverage detected