diff options
author | Alexander Early <alexander.early@gmail.com> | 2016-02-09 19:30:28 -0800 |
---|---|---|
committer | Alexander Early <alexander.early@gmail.com> | 2016-02-09 19:30:28 -0800 |
commit | 34f666a735d68eb563d1ff5d22fc85d176dcdcc2 (patch) | |
tree | efeab36210b24c58c5faae1817fb32d5e84ccbb5 /build/es/internal/parallel.js | |
parent | f4f2742270bc4c7f1325620bddc804379a8c0486 (diff) | |
download | async-34f666a735d68eb563d1ff5d22fc85d176dcdcc2.tar.gz |
move package manager files during build process, update main paths
Diffstat (limited to 'build/es/internal/parallel.js')
-rw-r--r-- | build/es/internal/parallel.js | 22 |
1 files changed, 22 insertions, 0 deletions
diff --git a/build/es/internal/parallel.js b/build/es/internal/parallel.js new file mode 100644 index 0000000..b532908 --- /dev/null +++ b/build/es/internal/parallel.js @@ -0,0 +1,22 @@ +'use strict'; + +import noop from 'lodash-es/noop'; +import isArrayLike from 'lodash-es/isArrayLike'; +import rest from 'lodash-es/rest'; + +export default function _parallel(eachfn, tasks, callback) { + callback = callback || noop; + var results = isArrayLike(tasks) ? [] : {}; + + eachfn(tasks, function (task, key, callback) { + task(rest(function (err, args) { + if (args.length <= 1) { + args = args[0]; + } + results[key] = args; + callback(err); + })); + }, function (err) { + callback(err, results); + }); +} |