node.js 延迟误解

Question

我正在学习 q.js 并尝试在它的帮助下同时查询 3 个集合（避免回调地狱）：

var Q = require('q')
var deferred = Q.defer();

users() 是 db.collection.find() 的包装器

var users = function (){
    Auth.listUsers({role:'user'}, call)
    return deferred.promise
}

call() 是导出承诺的简写

var call = function (err,data){
    if (err) {
        deferred.reject(err);
    } else {
        deferred.resolve(data);
    }
}

loop()是主循环，获取光标并遍历条目

var loop = function (result) {
    var list = []
    var promises = [];
    result.each(function (err,data){
        if (err) {
            deferred.reject(err);
        } else {
            deferred.resolve(data);
            promises.push(deferred.promise)
            console.log('promises_:', promises) // <- internal
        }
    })
    console.log('promises:', promises) // <- external
    return Q.all(promises)
}

代码：

users()
  .then(loop)
  .then(function(ful){
            console.log('ful:', ful);  // <- here should come the queries to other collections
        })

最后的控制台记录结果：

promises: []    //external is empty
ful: []
promises_: [ [object Object] ]  // internal is being filled
promises_: [ [object Object], [object Object] ]

如您所见，.each 的回调执行晚于将 Promise 推送到数组。 我相信它可以通过使用result.toArray() 而不是.each 来完成，但是如何在.each 循环的帮助下完成呢？

result 是一个游标，由 mongodb 驱动程序在 db.collection.find() 调用 (http://mongodb.github.io/node-mongodb-native/api-generated/collection.html#find) 后返回。

Answer 1

var deferred = Q.defer();
…
deferred.resolve(…);
…
deferred.resolve(…);

call() 是导出承诺的简写

那是行不通的！您需要为您想要的每个承诺创建一个新的 deferred。但是，你shouldn't use Deferreds anyway！相反，请使用 many Node callback helper functions。

---

如您所见， .each 的回调在将 Promise 推送到数组之后执行。我相信它可以通过使用 result.toArray() 而不是 .each 来完成，但是如何在 .each 循环的帮助下完成呢？

它不能，除非你事先知道each 被调用的频率以及需要创建多少个promise。 Q.all 在这里有点用处，因为 Promise 不是一次创建并并行执行它们的任务 - 相反，它们是一个流。

你真的应该在这里使用toArray，来获得一个你用来解决承诺的回调。

嗯，有一种方法，但它比toArray 丑而且效率低。你可以让一个 deferred 永远等待，并且只通过对流的其余部分的承诺来解决。

function loop(result) {
    var deferred = Q.defer();
    result.each(function (err,data){
        if (err) {
            deferred.reject(err);
        } else if (data == null) {
            deferred.resolve([]); // end of the stream
        } else {
            var nextDeferred = Q.defer();
            deferred.resolve(nextDeferred.promise.then(function(rest) {
                return [data].concat(rest);
            }));
            deferred = nextDeferred;
        }
    })
    return deferred.promise;
}