将 async 与异步函数一起使用

Question

我知道这听起来很愚蠢，但我不明白如何使用async 来处理现有的异步函数。

例如，考虑在某个节点模块中定义的一些异步函数foo(arg1, arg2, ..., argN, callback)。假设我想在async 的waterfall(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

是的，你所拥有的将起作用。 callback 只是告诉 async，“我完成了，转到下一个”。您还可以使用async.apply 自动生成这些小包装函数：

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