parent
2c4db660cf
commit
bd81d948c0
@ -0,0 +1,12 @@ |
|||||||
|
"use strict"; |
||||||
|
|
||||||
|
var async = require("async"); |
||||||
|
|
||||||
|
module.exports = function (params, processor) { |
||||||
|
var mapper = Function.bind.bind(processor.processTask, processor); |
||||||
|
return { |
||||||
|
process: function () { |
||||||
|
async.series(params.tasks.map(function (element) { return mapper(element); }), processor.done.bind(processor)); |
||||||
|
} |
||||||
|
}; |
||||||
|
}; |
Loading…
Reference in new issue