ノード・パイプHandle Input - node.js、非同期、ノード・ストリーム

テキストファイルから別のパイプにデータをパイプしていますいくつかのURLから画像をダウンロードしています。予想どおり、これにより多数のリクエストが連続して送信され、リモートサーバーがシャットダウンします。最初のチャンクが処理された後でのみ、次のチャンクを処理したいと思います。 私のコードは次のとおりです。

read.pipe(JSONStream.parse("*"))
.pipe(es.map(function (d, cb) {
download_images(x,y)
.then(function(r) ...)
.fail(function(r)  ...)
.fin(function(f) cb())
})
.pipe(xyz)

ストリームを調べ始めたばかりなので、非常に単純な点を見逃したか、ストリームを使用したいという熱意で、より良いアプローチを無視できたかもしれません。

• 非常に大きなjsonファイル
• 遅れて画像をダウンロードする

回答：

あなたは電話することができます read.pause() 電話をかける直前 download_images() その後電話する read.resume() 電話をかける直前 cb().