异步迭代器通过Symbol.asyncIterator返回Promise格式为{value,done}的对象，可用for await...of同步遍历异步数据流，如分页请求或文件读取；常使用async function*创建生成器，支持错误捕获与流式处理，需注意环境兼容性及不可用普通for...of遍历。
JavaScript异步迭代器是一种处理异步数据流的机制，适用于需要按顺序获取并处理异步结果的场景，比如从网络分页拉取数据或读取大量文件。它结合了异步操作（async/await）和迭代器协议，让开发者可以用类似同步的方式遍历异步生成的数据。
异步迭代器的基本概念
异步迭代器遵循 异步迭代协议，其核心是对象有一个 Symbol.asyncIterator 方法，调用后返回一个包含 next() 方法的对象。这个 next() 方法返回一个 Promise，Promise 的结果格式为 { value, done }。
例如，一个简单的异步迭代器可以这样实现：
const asyncIterable = {
[Symbol.asyncIterator]() {
let i = 0;
return {
next() {
if (i < 5) {
return Promise.resolve({ value: i++, done: false });
} else {
return Promise.resolve({ done: true });
}
}
};
}
};
然后你可以使用 for await...of 来遍历它：
(async () => {
for await (const value of asyncIterable) {
console.log(value); // 输出 0, 1, 2, 3, 4
}
})();
创建可复用的异步生成器
更常见的做法是使用 异步生成器函数，即在生成器函数前加上 async。这类函数会自动返回一个符合异步迭代协议的对象。
例如，模拟从 API 分页获取数据：
async function* fetchPages(url) {
let page = 1;
while (true) {
const response = await fetch(`${url}?page=${page}`);
const data = await response.json();
if (data.length === 0) break;
for (const item of data) {
yield item;
}
page++;}
}
使用方式依然简洁：
(async () => {
for await (const item of fetchP
ages('https://api.example.com/items')) {
console.log(item);
}
})();
异步遍历的应用场景
异步迭代特别适合以下情况：
ages('https://api.example.com/items')) {
console.log(item);
}
})();
- 逐条处理流式数据，如读取大型文件或数据库游标
- 分页请求远程接口，避免一次性加载过多数据
- 事件流或消息队列的有序消费
- 与 Node.js 中的 ReadableStream 配合使用
注意：不是所有环境都原生支持异步迭代器，老版本浏览器或 Node.js 需要通过 Babel 等工具转译。
注意事项
使用异步迭代时要注意错误处理。由于每一步都是异步的，应在 for await...of 中使用 try-catch 捕获异常：
(async () => {
try {
for await (const value of asyncIterable) {
console.log(value);
}
} catch (err) {
console.error('出错了:', err);
}
})();
另外，异步迭代器不能直接用普通 for...of 遍历，那样只会得到 Promise 对象，而不是实际值。
基本上就这些。掌握异步迭代器后，处理异步数据流会更加清晰和可控。
