diff --git a/BuildServer/lib/tasks/parallel.js b/BuildServer/lib/tasks/parallel.js new file mode 100644 index 0000000..65e8ac4 --- /dev/null +++ b/BuildServer/lib/tasks/parallel.js @@ -0,0 +1,17 @@ +"use strict"; + +var async = require("async"); + +module.exports = function (params, processor) { + return { + process: function () { + async.parallel(params.tasks.map(function (task) { + return function (callback) { + return processor.processTask(task, function (err) { + return callback(); + }) + } + }), processor.done.bind(processor)); + } + }; +};