从方法返回的 Promise 未定义

Question

我有一个接受函数作为回调参数的方法。外部方法和回调函数都返回我收集到数组的 Promise，等待它们被 Q.all 解决。

function eval() {
    var colReadPromisses = [];

    config.mongodb.colls.forEach(function (collName) {

        var outer = mongo.readCollection(collName,
                function (jsonData) {
                    var prom = es.pushItemToES(jsonData, esIndexName, collName, i);
                    colReadPromisses.push(prom);
                });
        colReadPromisses.push(outer);
    });

    return Q.all(colReadPromisses);
}

现在，内部回调方法被多次调用，并且需要一些时间来处理所有这些。在处理它们时，从“readCollection”方法返回的承诺变得“未定义”，导致“Q.all(colReadPromisses);”解决。

所以我的两个问题是为什么 nodejs 无法跟踪从“readCollection”方法返回的承诺，我该如何避免这种情况？

感谢您的回复！

Answer 1

我假设您想在返回的承诺中获取所有 readCollection 和 pushItemToES 的结果

function eval() {

    return Q.all(config.mongodb.colls.map(function (collName) {

        var pushPromisses = [mongo.readCollection(collName, function (jsonData) {
            pushPromisses.push(es.pushItemToES(jsonData, esIndexName, collName, i));
        })];

        return pushPromisses[0] // once the outer promise resolves
        .then(function() {
            return Q.all(pushPromisses); // wait for them all (including the outer)
        });

    }));
}

解析后返回的promise，将解析为二维数组

• [0][0] 将是 mongo.readCollection(colls[0]) 的结果
• [0][1..n] 将是来自 readCollection(colls[0]) 的每个 pushItemToES 的结果
• [1][0] will be the result of themongo.readCollection(colls[1])`
• [1][1..n] 将是来自 readCollection(colls[1]) 的每个 pushItemToES 的结果

等等

如果你不需要返回的promise中mongo.readCollection的结果

function eval() {

    return Q.all(config.mongodb.colls.map(function (collName) {

        var pushPromisses = [];

        return mongo.readCollection(collName, function (jsonData) {
            pushPromisses.push(es.pushItemToES(jsonData, esIndexName, collName, i));
        }).then(function() {
            return Q.all(pushPromisses);
        });

    }));
}

在这种情况下，返回的承诺仍然是二维的，但只有 pushItemToES 的结果

• [0][0..n] 将是来自readCollection(colls[0]) 的每个pushItemToES 的结果
• [1][0..n] 将是来自readCollection(colls[1]) 的每个pushItemToES 的结果

我在已解决的承诺中看不到二维数组周围的任何方式 - 因为 es.pushItemToES 没有被称为“已知”（至少不是提前）次数

Answer 2

你必须重新组织你的代码：

function eval() {
    // replace forEach with map
    var colReadPromisses = config.mongodb.colls.map(function (collName) {

           // return pushItemToES promises
            return new Promise(function(resolve) {
                mongo.readCollection(collName,
                    function (jsonData) {
                        resolve(es.pushItemToES(jsonData, esIndexName, collName, i));                   
                    });
            });

    });

    // colReadPromisses stores array of pushItemToES promises
    return Q.all(colReadPromisses);
}