summaryrefslogtreecommitdiff
path: root/build/es/internal/parallel.js
diff options
context:
space:
mode:
authorAlexander Early <alexander.early@gmail.com>2016-02-09 19:30:28 -0800
committerAlexander Early <alexander.early@gmail.com>2016-02-09 19:30:28 -0800
commit34f666a735d68eb563d1ff5d22fc85d176dcdcc2 (patch)
treeefeab36210b24c58c5faae1817fb32d5e84ccbb5 /build/es/internal/parallel.js
parentf4f2742270bc4c7f1325620bddc804379a8c0486 (diff)
downloadasync-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.js22
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);
+ });
+}