ES9 中的异步迭代

2023-12-08 00:31:11

异步迭代：JavaScript 中的强大工具

随着 JavaScript 不断进化，它引入了一系列令人兴奋的新特性来增强开发人员的工具集。其中一项显著的改进是异步迭代功能，它为处理异步数据流提供了简洁、高效的方法。

异步迭代的基础

异步迭代建立在 ES6 中引入的迭代器协议之上。迭代器是一个对象，它提供了一个 next() 方法，用于返回序列中的下一个值。在 ES9 中，异步迭代器是一个特殊的迭代器，它返回一个包含值的 Promise。

使用 for-await...of 循环进行异步迭代

ES9 引入了 for-await...of 循环，专门用于异步迭代。它采用以下语法：

for await (const element of iterable) {
  // 处理元素
}

在 for-await...of 循环中，迭代器由 iterable 提供，并且它会依次返回 Promise。每个 Promise 解析时，都会调用循环体，并且 element 变量将包含解析后的值。

异步数据流示例

让我们看一个异步数据流的示例，其中使用 for-await...of 循环进行异步迭代：

async function* fetchUsers() {
  const response = await fetch('https://example.com/users');
  const users = await response.json();
  for (const user of users) {
    yield user;
  }
}

(async () => {
  for await (const user of fetchUsers()) {
    console.log(user.name);
  }
})();

在这个示例中，fetchUsers 是一个异步生成器函数，它返回一个用户对象的流。for-await...of 循环异步地迭代 fetchUsers 函数返回的流，并逐个打印每个用户的名称。

使用 async iterators 进行自定义迭代

除了使用 for-await...of 循环，你还可以使用 async iterators 直接编写自定义的异步迭代器。async iterators 实现了 asyncSymbolIterator 符号，并且 next() 方法返回一个包含值的 Promise。

读取文件示例

让我们看一个读取文件并异步迭代其内容行的示例：

async function* readFile(path) {
  const file = await fs.promises.open(path, 'r');
  let buffer;
  do {
    buffer = await file.read();
    if (buffer && buffer.length > 0) {
      yield buffer.toString();
    }
  } while (buffer && buffer.length > 0);
}