Javascript Promise 过早解决

Question

我有一个返回 Promise 的函数，它访问数据库并拉出几行，将它们分配给 Javascript 变量。

问题是我的 '.then' 子句被触发，即使我知道 Promise 尚未解决：

app.post("/api/hashtag", function (req, res) {

FindPopularRumours().then(function (resolveVar) {
    console.log(resolveVar);
    console.log();
    res.send(resolveVar);
}).catch(function () {
    console.log("DB Error!");
    res.send("DB Error!");
});
});

还有 Promise 函数：

function FindPopularRumours() {
return new Promise((resolve, reject) => {
    var hashtags = [];
    var dbPromise;

    db.collection(HASHTAGS).find().forEach(function (doc) {
        hashtags.push(doc.hashtag);
        console.log(hashtags);
    });
    resolve(hashtags);
});
}

结果输出为：

[ ]

['#test1']

['#test1', '#test2']

['#test1', '#test2', '#test3']

如您所见，第一行 ('[ ]') 仅应在主题标签输出后执行。但由于某种原因，我的代码似乎认为 Promise 在实际解决之前就已经解决了。

编辑1

根据 Ankit 的建议，我将函数修改为：

function FindPopularRumours() {
return new Promise((resolve, reject) => {
    var hashtags = [];

    db.collection(HASHTAGS).find({}, function (err, doc) {
        if (!err) {
            doc.forEach(function (arg) {
                hashtags.push(arg.hashtag);
                console.log(hashtags);
            });
            resolve(hashtags);
        } else {
            return reject(err);
        }
    });
});
}

这仍然返回与以前相同的输出响应（例如，'then' 子句在承诺本身之前运行）。

我的POST功能还是和以前一样。

Answer 1

db.collection.find() 函数是异步的，所以你必须在 inside 的回调中解决 promise，类似于

function FindPopularRumours() {
    return db.collection(HASHTAGS).find().toArray().then( (items) => {
        return items.map( doc => doc.hashtag);
    });
}

利用 Mongo toArray() 方法，直接返回一个承诺

Answer 2

请注意db.collection(HASHTAGS).find() 是一个异步调用。因此，您的承诺在数据库查询返回之前得到解决。为了解决这个问题，你需要重写你的数据库查询如下：

function FindPopularRumours() {
    return new Promise((resolve, reject) => {
       var hashtags = [];
       var dbPromise;

       db.collection(HASHTAGS).find({}, function(err, doc){
           if(!err){
              doc.forEach(function (arg) {
                  hashtags.push(arg.hashtag);
                  console.log(hashtags);
              });
              resolve(hashtags);
           }else{
               return reject(err);
           }
       });
   });
}

希望答案对你有所帮助！