如何在发电机内使用等待？

Question

我有一个生成器,在其他操作中,查询数据库,如

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

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

这是无效的语法.使用承诺和屈服于a then也是不可能的.

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

Answer 1

awaitNode v10 +(2018年4月发布)和Chrome自v63以及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);
  }
}());

与常规(非异步)生成器相比,请记住await在调用之前使用.next().或者,新for-await-of语法自Node v9.2起可用,并且可以在没有任何标志的Node v10中使用.

对于旧版本的节点(或Jest),您可以使用Babel插件transform-async-generator-functions.