使用 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 <p>上述代码定义了一个 <code>AsyncNumberGenerator</code> 类。它通过 <code>[Symbol.asyncIterator]</code> 返回自身作为迭代器。<code>next()</code> 方法每次被调用时，都会返回一个 Promise，解析出当前的数值。当计数达到 <code>max</code> 时，返回 <code>done: true</code> 以终止迭代。</p><h2>如何处理异步迭代中的错误</h2><p>在 <code>for await...of</code> 循环中，如果 <code>next()</code> 返回的 Promise 被拒绝，或者循环体内抛出异常，整个循环会立即停止并抛出错误。可以使用 <code>try...catch</code> 块来捕获这些错误，确保程序不会崩溃。</p><div class="aritcle_card flexRow artxards">
<div class="artcardd flexRow">
<a class="aritcle_card_img" rel="nofollow" href="/xiazai/skill12835" title="JavaScript 测试模式"><img
src="https://img.php.cn/upload/skill/001/246/273/6adaf20cf0281539.jpg" alt="JavaScript 测试模式" onerror="this.onerror='';this.src='/static/lhimages/moren/morentu.png'" ></a>
<div class="aritcle_card_info flexColumn">
<a rel="nofollow" href="/xiazai/skill12835" title="JavaScript 测试模式" class="overflowclass">JavaScript 测试模式</a>
<p class="overflowclass">使用 Jest、Vitest 和 Testing Library 实施全面的测试策略，包括单元测试、集成测试和端到端测试，涵盖模拟、测试夹具和测试驱动开发。在编</p>
</div>
<a rel="nofollow" href="/xiazai/skill12835" title="JavaScript 测试模式" class="aritcle_card_btn flexRow flexcenter"><b></b><span>下载</span>
</a>
</div>
</div><p><img src="https://img.php.cn/upload/article/001/242/473/179470053141607.png?x-oss-process=image/resize,p_40" alt="JavaScript 中 for await of 怎么遍历异步迭代器"></p><pre class="brush:php;toolbar:false;">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 来处理每个数据包。这种方式避免了等待所有数据加载完毕后再处理，提高了响应速度和资源利用率。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
