從 10.0.0 版開始，異步迭代器就出現在 Node 中了，在本文中，我們將討論異步迭代器的作用，以及它們可以用在什么地方。

什么是異步迭代器

異步迭代器實際上是以前迭代器的異步版本。當我們不知道迭代的值和最終狀態時，可以使用異步迭代器。兩者不同的地方在于，我們得到的 promise 最終將被分解為普通的 { value: any, done: boolean } 對象，另外可以通過 for-await-of 循環來處理異步迭代器。就像 for-of 循環用于同步迭代器一樣。

const asyncIterable = [1, 2, 3]; 
asyncIterable[Symbol.asyncIterator] = async function*() { 
  for (let i = 0; i < asyncIterable.length; i++) { 
    yield { value: asyncIterable[i], done: false } 
  } 
  yield { done: true }; 
}; 
 
(async function() { 
  for await (const part of asyncIterable) { 
    console.log(part); 
  } 
})(); 

與通常的 for-of 循環相反，``for-await-of` 循環將會等待它收到的每個 promise 解析之后再繼續執行下一個。

除了流之外，還在還沒有什么能夠支持異步迭代的結構，但是可以將 asyncIterator 符號手動添加到任何一種可迭代的結構中。

在流上使用異步迭代器

異步迭代器在處理流時非常有用?？勺x流、可寫流、雙工流和轉換流上都帶有 asyncIterator 符號。

async function printFileToConsole(path) { 
  try { 
    const readStream = fs.createReadStream(path, { encoding: 'utf-8' }); 
 
    for await (const chunk of readStream) { 
      console.log(chunk); 
    } 
 
    console.log('EOF'); 
  } catch(error) { 
    console.log(error); 
  } 
} 

如果以這種方式寫代碼，就不需要在通過迭代獲取每個數據塊時監聽 end 和 data 事件了，并且 for-await-of 循環會隨著流的結束而結束。

用于有分頁功能的 API

你還可以通過異步迭代從使用分頁的源中輕松獲取數據。為了實現這個功能，還需要一種從Node https 請求方法提供給的流中重構響應主體的方法。在這里也可以使用異步迭代器，因為 https 請求和響應在 Node 中都是流：

const https = require('https'); 
 
function homebrewFetch(url) { 
  return new Promise(async (resolve, reject) => { 
    const req = https.get(url, async function(res) { 
      if (res.statusCode >= 400) { 
        return reject(new Error(`HTTP Status: ${res.statusCode}`)); 
      } 
 
      try { 
        let body = ''; 
 
        /* 
          代替 res.on 偵聽流中的數據， 
          可以使用 for-await-of， 
          并把數據塊附加到到響應體的剩余部分 
        */ 
        for await (const chunk of res) { 
          body += chunk; 
        } 
     
        // 處理響應沒有響應體的情況 
        if (!body) resolve({}); 
  // 需要解析正文來獲取 json，因為它是一個字符串 
        const result = JSON.parse(body); 
        resolve(result); 
      } catch(error) { 
        reject(error) 
      } 
    }); 
 
    await req; 
    req.end(); 
  }); 
} 

代碼通過向 Cat API(https://thecatapi.com/)發出請求，來獲取一些貓的圖片。另外還添加了 7 秒鐘的延遲防止對 cat API 的訪問過與頻繁，因為那樣是極其不道德的。

function fetchCatPics({ limit, page, done }) { 
  return homebrewFetch(`https://api.thecatapi.com/v1/images/search?limit=${limit}&page=${page}&order=DESC`) 
    .then(body => ({ value: body, done })); 
} 
 
function catPics({ limit }) { 
  return { 
    [Symbol.asyncIterator]: async function*() { 
      let currentPage = 0; 
      // 5 頁后停止 
      while(currentPage < 5) { 
        try { 
          const cats = await fetchCatPics({ currentPage, limit, done: false }); 
          console.log(`Fetched ${limit} cats`); 
          yield cats; 
          currentPage ++; 
        } catch(error) { 
          console.log('There has been an error fetching all the cats!'); 
          console.log(error); 
        } 
      } 
    } 
  }; 
} 
 
(async function() { 
  try { 
    for await (let catPicPage of catPics({ limit: 10 })) { 
      console.log(catPicPage); 
      // 每次請求之間等待 7 秒 
      await new Promise(resolve => setTimeout(resolve, 7000)); 
    } 
  } catch(error) { 
    console.log(error); 
  } 
})() 

這樣，我們就會每隔7秒鐘自動取回一整頁的喵星人圖片。

一種更常見的頁面間導航的方法可實現 next 和 previous 方法并將它們公開為控件：

function actualCatPics({ limit }) { 
  return { 
    [Symbol.asyncIterator]: () => { 
      let page = 0; 
      return { 
        next: function() { 
          page++; 
          return fetchCatPics({ page, limit, done: false }); 
        }, 
        previous: function() { 
          if (page > 0) { 
            page--; 
            return fetchCatPics({ page, limit, done: false }); 
          } 
          return fetchCatPics({ page: 0, limit, done: true }); 
        } 
      } 
    } 
  }; 
} 
 
try { 
    const someCatPics = actualCatPics({ limit: 5 }); 
    const { next, previous } = someCatPics[Symbol.asyncIterator](); 
    next().then(console.log); 
    next().then(console.log); 
    previous().then(console.log); 
} catch(error) { 
  console.log(error); 
} 

如你所見，當要獲取數據頁面或在程序的 UI 上進行無限滾動之類的操作時，異步迭代器會非常有用。

這些功能在 Chrome 63+、Firefox 57+、Safari 11.1+ 中可用。