Javascript异步生成器改变产生值的类型？

Question

所以我有一些生成器方法，它通过调用另一个方法来获取数据，该方法返回分页数据。此生成器迭代最近的缓冲区和yields 每个项目，直到没有更多可获取的数据。

async function* paginated_generator(source, opts = {}) {
    buffer = await source(opts)
    while (true) {
        for (let item of buffer.items) {
            yield item
        }
        if (!buffer.paging.next) {
            break
        }
        buffer = await source({ ...opts, next: buffer.paging.next })
    }
}

在这种情况下，它正在调用的方法如下所示，并为每条数据构造一个新的Notification 实例。

async notifications_paginated(opts = {}) {
    let Notification = require('./Notification')
    let instance = this || opts.instance

    let data = await paginated_data(`${instance.api}/news/my`, {
        limit: opts.limit || instance.paginated_size,
        key: 'news',
        prev: opts.prev,
        next: opts.next,
        headers: instance.headers
    })

    data.items = data.items.map((item) => new Notification(item))
    return data

}

当我直接从此方法获取数据，或者在生成器生成之前在生成器中插入类似console.log(item.some_getter) 的内容时，我可以看到该对象是Notification 类的一个实例。但是，如果我 await 生成器方法的下一个值，则它产生的数据无法访问附加到 Notification 对象的任何方法或 getter。

当这个数据从生成器返回时发生了什么变化？

Answer 1

您没有正确使用异步生成器，但在我们开始之前，让我们稍微清理一下实现：

async function* paginated_generator(source, opts = {}) {
    let buffer = await source(opts)

    while (true) {
        yield * buffer.items

        if (!buffer.paging.next) return

        buffer = await source({ ...opts, next: buffer.paging.next })
    }
}

当您调用异步生成器函数时，它会返回一个异步生成器对象，该对象实现了异步迭代器和异步可迭代协议。

生成器函数和迭代协议的异步和同步对应物的语法和协议之间存在一些差异：

• async iterator protocol 的next() 方法返回Promise<{ value: T, done: boolean }>，而iterator protocol 只返回{ value: T, done: boolean }。
• 异步迭代使用Symbol.asyncIterator 方法而不是Symbol.iterator 方法。
• 可以使用 for await...of 而不是 for...of 来使用异步迭代。

根据您提供的上下文，您的用法（可能）应该如下所示：

const Notification = require('./Notification')

async* notifications_paginated (opts = {}) {
    const instance = this || opts.instance
    const gen = paginated_data(`${instance.api}/news/my`, {
        limit: opts.limit || instance.paginated_size,
        key: 'news',
        prev: opts.prev,
        next: opts.next,
        headers: instance.headers
    })

    for await (const item of gen) {
        yield new Notification(item)
    }
}

然后，您可以将 notifications_paginated() 用作 Notification 对象的异步迭代器或异步迭代器。

如果您在返回之前尝试缓冲 notifications_paginated() 中的所有项目，那么您的 API 可能根本不使用分页，因为缓冲项目首先会破坏分页的目的。