什么是JavaScript中的异步迭代_如何使用for-await-of处理异步数据?

for-await-of 用于按序消费异步迭代器,自动 await 每次 next() 返回的 Promise;需对象实现 [Symbol.asyncIterator](),如 async function*、ReadableStream;不适用于高并发场景。

JavaScript 中的异步迭代是一种让 for...of 循环能处理异步可迭代对象(比如返回 Promise 的迭代器)的机制,核心是 for-await-of 语句。它专为消费异步迭代器(AsyncIterator)而设计,会自动等待每次 next() 返回的 Promise 解析后再继续下一次迭代。

异步迭代器是什么?

普通迭代器的 next() 方法返回一个形如 { value, done } 的同步对象;而异步迭代器的 next() 方法返回的是一个 Promise,该 Promise resolve 后才得到 { value, done }。要让一个对象支持 for-await-of,它必须实现 [Symbol.asyncIterator]() 方法。

  • 内置支持异步迭代的对象包括:异步生成器函数(async function*)返回的实例、ReadableStream(如 Fetch API 的响应体)
  • 自定义异步迭代器需手动实现 [Symbol.asyncIterator],且其 next() 必须返回 Promise

如何用 for-await-of 消费异步数据?

语法与 for...of 几乎一致,只是把 of 换成 await of。引擎会自动 await 每次迭代的值,无需手动写 await

例如,读取一个 Response.body 流:

const response = await fetch('/data.json');
const reader = response.body.getReader();
for await (const chunk of reader) {
  console.log('Received chunk:', chunk);
}

再比如,用异步生成器模拟分页请求:

async function* fetchPages() {
  let page = 1;
  while (page <= 3) {
    const res = await fetch(`/api/items?page=${page}`);
    yield await res.json();
    page++;
  }
}

for await (const data of fetchPages()) { console.log(data); // 每次拿到一页 JSON 数据,自动等待完成 }

注意事项和常见陷阱

for-await-of 只能在 async 函数或模块顶层(ES2025+)中使用,否则会报语法错误。

  • 不能在普通函数里直接使用,必须包裹在 async 函数中
  • 如果异步迭代器某次 next() 抛出异常(比如网络失败),循环会提前终止,并将错误抛出到 for-await-of 所在作用域,可用 try...catch 捕获
  • 不适用于普通数组或同步可迭代对象——它们没有 [Symbol.asyncIterator],会报 TypeError: X is not async iterable

与 Promise.all + map 的区别

for-await-of 是**顺序执行**:等前一个 Promise 完成后才开始下一个。而 Promise.all([...].map(async () => {...})) 是**并发执行**所有异步操作。

  • 适合按序处理(如流式解析、防止接口限频、依赖上一步结果)
  • 不适合需要最大化并行度的场景(此时应选 Promise.allPromise.allSettled