Node.js の非同期イテレータの詳細な説明

非同期イテレータの定数は[1, 2, 3]です。
asyncIterable[Symbol.asyncIterator] = 非同期関数*() {
  (i = 0 とします; i < asyncIterable.length; i++) {
    yield { 値: asyncIterable[i], 完了: false }
  }
  結果: true
};

(非同期関数() {
  for await (asyncIterable の const 部分) {
    console.log(一部);
  }
})();

非同期関数 printFileToConsole(path) {
  試す {
    const readStream = fs.createReadStream(path, { エンコーディング: 'utf-8' });

    for await (const chunk of readStream) {
      console.log(チャンク);
    }

    console.log('EOF');
  } キャッチ(エラー) {
    コンソール.log(エラー);
  }
}

定数 https = require('https');

関数 homebrewFetch(url) {
  新しい Promise(async (resolve, reject) => { を返します。
    const req = https.get(url, 非同期関数(res) {
      （res.statusCode >= 400）の場合{
        拒否を返します(新しいエラー(`HTTP ステータス: ${res.statusCode}`));
      }

      試す {
        本文を '' とします。

        /*
          ストリーム内のデータをリッスンする代わりに、
          for-await-ofを使用してデータチャンクを追加することができます
          レスポンス本文の残りの部分*/
        for await (const chunk of res) {
          本体 += チャンク;
        }
    
        // 本文がない場合の処理​​ if (!body) resolve({});
        // 本文は文字列なので、JSON を取得するには解析する必要があります。const result = JSON.parse(body);
        解決(結果);
      } キャッチ(エラー) {
        拒否(エラー)
      }
    });

    要求を待機します。
    要求を終了します();
  });
}

関数 fetchCatPics({ limit, page, done }) {
  homebrewFetch を返します(`https://api.thecatapi.com/v1/images/search?limit=${limit}&page=${page}&order=DESC`)
    .then(本文 => ({ 値: 本文、完了 }));
}

関数catPics({limit}){
  戻る {
    [Symbol.asyncIterator]: 非同期関数*() {
      現在のページを 0 にします。
      // 5ページ後に停止
      現在のページが 5 未満の場合
        試す {
          const cats = fetchCatPics({ currentPage, limit, done: false }) を待機します。
          console.log(`${limit} 匹の猫を取得しました`);
          猫を飼う;
          現在のページ++;
        } キャッチ(エラー) {
          console.log('すべての猫を取得中にエラーが発生しました!');
          コンソール.log(エラー);
        }
      }
    }
  };
}

(非同期関数() {
  試す {
    for await (let catPicPage of catPics({ limit: 10 })) {
      コンソールにログ出力します。
      // リクエスト間で7秒間待機する
      新しい Promise(resolve => setTimeout(resolve, 7000)) を待機します。
    }
  } キャッチ(エラー) {
    コンソール.log(エラー);
  }
})()

関数actualCatPics({limit}){
  戻る {
    [シンボル.asyncIterator]: () => {
      ページを 0 にします。
      戻る {
        次へ: 関数() {
          ページ++;
          fetchCatPics({page,limit,done:false}) を返します。
        },
        前: 関数() {
          (ページ > 0) {
            ページ - ;
            fetchCatPics({page,limit,done:false}) を返します。
          }
          fetchCatPics({ page: 0, limit, done: true }); を返します。
        }
      }
    }
  };
}

試す {
    const someCatPics = 実際のCatPics({ 制限: 5 });
    const { next, previous } = someCatPics[Symbol.asyncIterator]();
    次に（）します。その後（console.log）;
    次に（）します。その後（console.log）;
    前回の().その後(console.log);
} キャッチ(エラー) {
  コンソール.log(エラー);
}