使用 for await...of 语句可以遍历异步迭代器，它会自动等待每个 promise 的解析结果。在循环体内部直接处理数据即可，无需手动调用 .then() 或 await 单个元素。
如何定义一个支持异步迭代的对象
要实现异步迭代器，对象必须实现 [Symbol.asyncIterator] 方法，该方法返回一个包含 next() 方法的迭代器对象。next() 方法必须返回一个 Promise，该 Promise 解析为一个包含 value 和 done 属性的对象。
class AsyncNumberGenerator {
constructor(max) {
this.max = max;
this.current = 0;
}
[Symbol.asyncIterator]() {
return this;
}
next() {
if (this.current < this.max) {
const value = this.current++;
// 模拟异步操作，例如网络请求或定时器
return Promise.resolve({ value: value, done: false });
} else {
return Promise.resolve({ value: undefined, done: true });
}
}
}上述代码定义了一个 AsyncNumberGenerator 类。它通过 [Symbol.asyncIterator] 返回自身作为迭代器。next() 方法每次被调用时，都会返回一个 Promise，解析出当前的数值。当计数达到 max 时，返回 done: true 以终止迭代。
立即学习“Java免费学习笔记（深入）”；
如何处理异步迭代中的错误
在 for await...of 循环中，如果 next() 返回的 Promise 被拒绝，或者循环体内抛出异常，整个循环会立即停止并抛出错误。可以使用 try...catch 块来捕获这些错误，确保程序不会崩溃。
async function processAsyncData() {
const generator = new AsyncNumberGenerator(5);
try {
for await (const num of generator) {
console.log(num);
if (num === 3) {
throw new Error('Stop at 3');
}
}
} catch (error) {
console.error('Error caught:', error.message);
}
}
processAsyncData();这段代码展示了如何在循环中处理错误。当 num 等于 3 时，手动抛出一个错误。由于使用了 try...catch，错误会被捕获并打印，而不会导致程序未处理的异常退出。如果没有 try...catch，错误将向上传播，可能导致程序终止。
异步迭代器在流式数据处理中的应用
异步迭代器非常适合处理流式数据，例如从文件读取大文件或从网络接收实时数据流。在这种情况下，数据不是一次性全部加载到内存中，而是分块到达。使用 for await...of 可以逐块处理数据，保持内存效率。
假设有一个模拟的网络流，每秒钟发送一个数据包。我们可以创建一个异步迭代器来模拟这种流，并使用 for await...of 来处理每个数据包。这种方式避免了等待所有数据加载完毕后再处理，提高了响应速度和资源利用率。
