09-3 (付費) 數據洪流：異步迭代與 Streams

1. 異步迭代器 (Async Iterators)

當 next() 回傳的是一個 Promise 時，我們稱之為異步迭代器。

const asyncSource = {
  [Symbol.asyncIterator]() {
    let i = 0;
    return {
      async next() {
        await new Promise(r => setTimeout(r, 1000)); // 模擬延遲
        if (i < 3) return { value: i++, done: false };
        return { done: true };
      }
    };
  }
};

(async () => {
  for await (const val of asyncSource) {
    console.log(val); // 每秒鐘印出一個數字
  }
})();

2. 異步產生器 (Async Generators)

結合 async 與 *，它是處理分頁 API 的神器。

async function* fetchPages(url) {
  let currUrl = url;
  while (currUrl) {
    const response = await fetch(currUrl);
    const data = await response.json();
    currUrl = data.nextPage;
    yield data.items;
  }
}

3. Web Streams API

這是處理原始二進位數據的最核心工具（例如：正在下載的檔案）。

const response = await fetch(url);
const reader = response.body.getReader();

while (true) {
  const { done, value } = await reader.read();
  if (done) break;
  console.log(`收到 ${value.length} bytes 的數據`);
}