forEach 的简单承诺

Question

我正在尝试使用 Promise 来等待异步 forEach：

var forEachMatch = function(matches) {
    var deferred = Q.defer();
    matches.forEach(function(match) {
        var messages = Message.find({'matchid': match._id}, function(err,messages) {
            if(err)
                console.log(err);
            else
                console.log(match._id);
        });
    });
    return deferred.promise;
};

在这里使用：

forEachMatch(matches, function() {
    console.log("DONE");
    res.status(200).json({
        bob,
        matches: matches,
    });
});

我的控制台输出如下：所有match._id 都已打印，但DONE 从未打印。

有解决办法吗？我从 node 和 promises 开始，所以我肯定会忘记一些东西，但我看不到什么。

感谢您的任何回答。

编辑

最终的解决方案，感谢 Alexander Mac：

var forEachMatch = function(matches) {
  var promises = matches.map(match => {
    return Message
    .find({'matchid': match._id})
    .populate({
      path: 'fromUser toUser',
      select: 'id firstname'
    })
    .then(messages => [match, messages])
    .catch(err => {
      console.log("Error in forEachMatch");
      return [match, null];
    });
  });
  return Q.all(promises);
}

forEachMatch(matches)
  .then(messagesByMatch => {
    res.status(200).json({
      user,
      messagesByMatch: messagesByMatch
    });
  });

Answer 1

在您的情况下，最好使用Q.all，它接受承诺或值的数组：

var forEachMatch = function(matches) {
  var promises = matches.map(match => {
    return Message
      .find({'matchid': match._id})
      .then(messages => [match, messages]);
  });
  return Q.all(promises);
}

forEachMatch(matches)
  .then(results => {
    console.log("DONE", results);
    res.status(200).json({
      bob,
      matches: matches,
  });
});

https://github.com/kriskowal/q/wiki/API-Reference#promiseall

Answer 2

您正在返回一个延迟的承诺，并且该承诺没有得到解决或拒绝。请尝试以下操作：

var forEachMatch = function(matches) {
var deferred = Q.defer();
matches.forEach(function(match) {
    var messages = Message.find({'matchid': match._id}, function(err,messages) {
        if(err)
            deferred.reject(err);
        else
            deferred.resolve(match._id);
    });
});
return deferred.promise;

};

调用者会变成

    forEachMatch(matches).then(id=>{

     console.log("done succesffuly found");

   }).catch(err=>{
         console.log("not found error",err);
   }).done(()=>{
         console.log("done")
   });

Answer 3

您从未调用过promise.reject 或promise.reject 方法。此外，对异步操作做出了承诺，而 forEach 则没有。

这是一个肮脏的修复：

 var forEachMatch = function(matches) {
  var deferred = Q.defer();
  // make the foreach asynchronous
  setTimeout(function() {
    matches.forEach(function(match) {
      // do stuff
    });
    // notify end
    deferred.resolve();
  }, 0);

  return deferred.promise;
};

// use .then
forEachMatch(matches).then(function() {
  console.log("DONE");
});