Использование async с асинхронными функциями

Question

Я знаю, это звучит глупо, но я не могу понять, как использовать async для обработки существующих асинхронных функций.

Например, рассмотрим некоторую асинхронную функцию foo(arg1, arg2, ..., argN, callback), определенную в некотором модуле узла. Скажем, я хочу использовать это в функции asyncwaterfall(tasks,[callback]). Как я мог это сделать?

//original call 
foo(x1,x2,xN, function goo(err, res) { 
    // do something 
}); 

//using async 
async.waterfall([ 
    function(callback) { 
     foo(x1,x2,...,xN, callback); 
    } 
], function goo(err, res) { 
    // do something 
}); 

, но я не могу этого сделать, так как callback должна быть вызвана до конца функции. Помощь?

Answer 1

Yup, что у вас будет работать. callback просто говорит async: «Я закончил, перейдите к следующему». Вы также можете использовать async.apply для генерации этих небольших функций обертки автоматически:

async.waterfall([ 
    async.apply(foo, x1, x2, nX) //don't use callback, async will add it, 
    someOtherFunction 
], function (error, finalResult) {});