1

我有一个使用await调用的异步函数，我认为当你使用时await，它应该暂停函数执行，直到它收到它的值。出于某种原因，它对我不起作用。

这是我的函数（它在一个类中）：

async userExistsInDB(email) {
    let userExists;
    await MongoClient.connect('mongodb://127.0.0.1:27017/notificator', async(err, db) => {
        if (err) throw err;

        let collection = db.collection('users');
        userExists = await collection.find({email: email}).limit(1).count() > 0;
        console.log("INSIDE:\n", userExists);
        db.close();
    });
    console.log("OUTSIDE:\n", userExists);
    return userExists;
}

这是我在同一个类中的另一个函数中调用它的方式：

async getValidationErrors(formData) {
   let userExists = await this.userExistsInDB(formData.email);
   console.log("ANOTHER FUNC:\n", userExists);
}

所以，我得到以下输出：

OUTSIDE:
 undefined
ANOTHER FUNC:
 undefined
INSIDE:
 true

尽管INSIDE: true我希望首先打印的值。

基本上，我需要的是userExists从userExistsInDB函数中获取布尔值并在其他代码中使用它。

我在这里做错了什么？

4

1 回答 1

5

await仅适用于承诺，因此MongoClient.connect(…)需要返回承诺。然而，您将它用作回调 API，甚至使用async（承诺返回）回调函数，这将不起作用。假设如果你不传递回调，mongo 返回承诺，你的代码应该看起来像

async function userExistsInDB(email) {
    let db = await MongoClient.connect('mongodb://127.0.0.1:27017/notificator');
    let collection = db.collection('users');
    let userExists = (await collection.find({email: email}).limit(1).count()) > 0;
    db.close();
    return userExists;
}

虽然理想情况下你宁愿这样做

async function userExistsInDB(email) {
    let db = await MongoClient.connect('mongodb://127.0.0.1:27017/notificator');
    try {
        let collection = db.collection('users');
        let userCount = (await collection.find({email: email}).limit(1).count();
        return userCount > 0;
    } finally {
        db.close();
    }
}
于 2015-10-31T13:49:47.820 回答