异步方法链接？ [复制]答案

【问题标题】：Async Method Chaining? [duplicate]异步方法链接？ [复制]
【发布时间】：2025-11-23 07:05:04
【问题描述】：

我正在尝试使用异步方法链接创建一个类。但是，在从数据库中完全获取数据之前，我仍在设置新值。我错过了什么吗？

我也不想使用任何第三方模块。

/* Class */

class UserDB {
    constructor() {
        this.user = {}
        this.user.username = null
    }

    set(name, value) {
        this.user[name] = value
        return this
    }

    update() {
        return new Promise((resolve, reject) => {
            const db = MongoConnection.client.db('database').collection('users')
            db.updateOne({ _id: this.user._id }, { $set: this.user}, (err, result) => {
                if (err) reject(err)
                resolve(this)
            })
        })
    }

    findByEmail(email) {
        return new Promise((resolve, reject) => {
            const db = MongoConnection.client.db('database').collection('users')
            db.findOne({ email: email }, (err, result) => {
                if (err) reject(err)
                this.user = result
                resolve(this)
            })
        })
    }
}

module.exports = UserDB


/*execution*/

new UserDB().findByEmail('email@email.com')
    .set('username', 'new_name')
    .update()

【问题讨论】：

异步函数返回 Promise，因此如果不更改 Promise 类本身，就无法真正像那样链接它们。为什么你认为你需要这些函数是异步的？
好吧...您可以像这样链接异步方法，但是，它必须以这样一种方式工作，即您实际上正在做的是设置您想要发生的事情链.对于 xmaple，.set() 将无法直接访问 fetchData 的结果，因为 set() 将在 fetchData() 完成其异步操作之前运行。这样一个系统的设置将非常遵循您使用 this 关键字发现 WRT 链接的现有信息。
另见*.com/a/43880581/1048572
@LeeDanielCrocker 我更多地考虑使用回调。我看到许多模块使用链式方法进行异步操作来操作数据库。
对，有 db 模块可以让您通过链接几个方法来构建查询，然后通过调用 .exec() 来执行查询。这将使用 this 关键字或类似设置来完成。

标签： javascript node.js asynchronous

【解决方案1】：

这确实很有趣。您可以使用将操作附加到 .then 链的方法重载返回的 Promise：

 class AsyncChainable {
   constructor() {
    this._methods = {};

    const that = this;
    for(const key of  Object.getOwnPropertyNames(Object.getPrototypeOf(this))) {
     this._methods[key] = function(...args) {
       return that.chain(this.then(() => that[key](...args)));
    }
  }

  chain(promise) { return Object.assign(promise, this._methods); }
}

然后在你的自定义类中使用它：

 class User extends AsyncChainable {
   login() {
    return this.chain((async () => {
     // some logic
    })());
  }
}

这样你就可以做到：

 (new User).login().login().then(console.log);

【讨论】：