Node.jsデザインパターン 第2版

132

5

章 ストリーム

細は長くなるため、そういったストリームの実装はここでは紹介しません。たとえば

through2-

parallel

（

https://npmjs.org/package/through2-parallel

）などを使うことで可能になります。

既存のモジュール

checkUrls

を変更することで、順序付き並行実行の様子をチェックできます。

チェックを並行に実行する間、入力ファイルの

URL

と同じ順番で書かれた結果が欲しいとしましょう。

through2-parallel

を使って次のように実 行できます（

16_streams_ordered_parallel_

execution

）。

// ...

const throughParallel = require('through2-parallel');

fs.createReadStream(process.argv[2])

.pipe(split())

.pipe

(throughParallel.obj({concurrency: 2},(url, enc, done) => {

// ...

})

)

.pipe(fs.createWriteStream('results.txt'))

.on('finish', () => console.log('All urls were checked'));

through2-parallel

のインタフェースは

through2

のものとよく似ています。唯一の違いは指定

するトランスフォーム ...