我如何在生成器中使用等待？

Question

我有一个生成器，除其他操作外，它还可以查询数据库，例如

function* current(db) {
  const items = await db.collection('...').find({ ... });

  for (const item of items)
    if (...) yield item;
}

这不是有效的语法。使用 promises 并从 then 中产生也是不可能的。

那我该怎么办？如何在生成器中使用异步操作？

Answer 1

您不能将异步与生成器函数结合使用。那就是说你很可能不想在你的情况下使用生成器，而只是有一个异步函数：

async function current(db) {
  while (true) {
    const latest = await db.collection('messages').findOne({}, {
      sort: {
        timestamp: -1
      }
    });

    return smth;
  }
}

生成器 将在 async 被转译时为您生成 。

Answer 2

在生成器（也称为异步生成器）中调用 await 已在 Node v10+（已发布 April 2018) and Chrome since v63, as well as Firefox v57.

中得到原生支持

function sleep(ms) {
  return new Promise(resolve => setTimeout(resolve, ms));
}

async function getAsyncData() {
  await sleep(1000);  // simulate database/network delay...
  return [1, 2, 3, 4, 5];  // ...then return some data
}

// async generator
async function* filterAsyncData() {
  const items = await getAsyncData();  // await call in generator
  
  for (const item of items)
    if (item % 2) yield item;
}

(async function main() {
  // for-await syntax
  for await (const filteredItem of filterAsyncData())
    console.log(filteredItem);
  
  // classic iterator syntax
  const fadIt = filterAsyncData();
  while (true) {
    const result = await fadIt.next();  // note await
    if (result.done) break;
    console.log(result.value);
  }
}());

与常规（非异步）生成器相比，请记住在调用 .next() 之前使用 await。或者，新的 for-await-of 语法从 Node v9.2 开始可用，并且可以在没有任何标志的情况下在 Node 10 中使用。

对于旧版本的节点（或 Jest），您可以使用 Babel 插件 transform-async-generator-functions。

我如何在生成器中使用等待？

How do I use await inside a generator?

asynchronous

generator

async-await

ecmascript-6