Node.js 中異步迭代器如何使用

這篇文章將為大家詳細講解有關Node.js 中異步迭代器如何使用，文章內容質量較高，因此小編分享給大家做個參考，希望大家閱讀完這篇文章后對相關知識有一定的了解。

什么是異步迭代器

異步迭代器實際上是以前迭代器的異步版本。當我們不知道迭代的值和最終狀態時，可以使用異步迭代器。兩者不同的地方在于，我們得到的  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 符號手動添加到任何一種可迭代的結構中。

在流上使用異步迭代器

異步迭代器在處理流時非常有用。可讀流、可寫流、雙工流和轉換流上都帶有 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); }

關于Node.js 中異步迭代器如何使用就分享到這里了，希望以上內容可以對大家有一定的幫助，可以學到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。