如何使用 Mongoose 方法实现异步

Question

我现在有以下代码：

exports.listByUser = function(req, res) {
    Attack.find({user: req.user._id}, function(err, attacks) {
        if(err) 
            return next(err);
        for(var i in attacks) {
            attacks[i].evaluateFight();
        }
        res.json(attacks);
    });
};

主要问题是attacks[i].evaluateFight()被异步调用，我想对其进行改造以确保完成[i-1]迭代......最后调用res.json(attacks)。我认为，它可以用async 完成，但我不知道如何:( 这样的东西应该可以工作，但我怎么能打电话给attacks.method？

async.eachSeries(attacks, function (callback) {
  //something??
  callback();
}, function (err) {
  if (err) { throw err; }
  res.json(attacks);
});

Answer 1

您可以利用 async whilst 方法调用来实现相同的功能。但是，我对evaluateFight 的回调有疑问，因为如果它是异步执行的，那么必须有一些与之关联的回调，它将通知上一次调用是否成功。

示例代码可以如下假设evaluateFight在完成时返回一个回调 -

exports.listByUser = function(req, res) {
Attack.find({user: req.user._id}, function(err, attacks) {
    if(err) 
        return next(err);
    var attacksLength = attacks.length;
    var count = 0;

    async.whilst(function () { 
          return count < attacksLength; 
       },
       function (callback) {

          attacks[count].evaluateFight(function(err, result){
             count++;
             callback();
          }); // assuming it returns a callback on success

        },
      function (err) {
         // all the iterations have been successfully called 
        // return the response
        res.json(attacks);
     });

};