async函数返回asynciterator时异常分两阶段：创建阶段异常需在await调用处用try/catch捕获；遍历阶段异常需在for await或手动next()/throw()/return()中捕获，内部也可加try/catch实现容错。
async 函数返回异步迭代器（AsyncIterator）时，异常可能发生在两个阶段：创建迭代器时（即 async function 执行体内部抛出错误），或在后续调用 next()、throw()、return() 时抛出。处理的关键是分清异常发生时机，并在对应位置捕获。
创建阶段的异常：在 await 调用处捕获
如果 async 函数体在首次执行（即生成迭代器对象前）就抛出错误，该错误会直接拒绝由该函数返回的 Promise —— 注意：此时根本没生成迭代器，更谈不上遍历。
例如：
async function badAsyncGen() {
throw new Error("初始化失败");
return { async *[Symbol.asyncIterator]() { yield 1; } };
}
// 下面这行会立即 reject，不会等到 for await
await badAsyncGen(); // ❌ 抛出 "初始化失败"
✅ 正确做法：用 try/catch 包裹对 async 函数的调用：
- 确保在
await函数返回值前捕获初始化错误 - 若函数返回的是一个可迭代对象（如含
[Symbol.asyncIterator]的对象），需先成功获取该对象，再进入遍历
遍历阶段的异常：在 for await 或手动 next() 中捕获
一旦异步迭代器成功创建，后续每次 next() 返回的 Promise 都可能被拒绝（比如内部 await fetch() 失败、数据库查询出错等）。这类异常需在消费端处理。
✅ 推荐方式：用 for await...of 配合 try/catch：
async function fetchItems() {
for (const id of [1, 2, 3]) {
const res = await fetch(`/api/item/${id}`);
if (!res.ok) throw new Error(`HTTP ${res.status}`);
yield await res.json();
}
}
<p>// 消费时捕获遍历中抛出的异常
try {
for await (const item of fetchItems()) {
console.log(item);
}
} catch (err) {
console.error("遍历时出错：", err.message); // ✅ 捕获 fetch 失败等
}
</p>
⚠️ 注意：for await 遇到拒绝的 next() Promise 会立即退出循环并抛出错误，不会继续迭代。
主动触发 throw() 或 return() 时的异常处理
异步迭代器协议支持 throw(error) 向内部传递错误（类似 generator 的 iterator.throw()），也支持 return() 提前终止。这些方法本身返回 Promise，也可能被拒绝。
✅ 若你手动调用 iterator.throw()，需 await 并捕获：
-
await iterator.throw(new Error("中断"))可能被拒绝（例如内部没有catch处理该错误） -
await iterator.return()也可能被拒绝（比如清理逻辑中抛出错误）
实际中较少手动调用，但框架或工具库（如某些流式处理库）可能使用，这时需按 Promise 方式处理其返回值。
统一兜底：在 async 迭代器内部加 try/catch
若希望迭代器自身消化部分错误（例如跳过单条失败数据而非整个中断），应在 async function* 内部包裹关键异步操作：
async function* resilientFetch() {
for (const url of urls) {
try {
const res = await fetch(url);
if (!res.ok) throw new Error(`Failed: ${url}`);
yield await res.json();
} catch (err) {
console.warn(`跳过 ${url}：`, err.message);
continue; // 继续下一次 yield，不中断迭代
}
}
}
这样外部 for await 就不会因单次失败而退出，提升健壮性。
