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

5.2

 ストリームの基本的な使い方

115

関数

_read()

への入力に指定された引数

size

は無視されます（アドバイザリ引数）。単純に利用可

能なデータをプッシュできます。しかし同じ呼び出しの中で複数のプッシュがあるときは

push()

が

false

を戻すかチェックしなければなりません。

false

は内部バッファが上限

highWaterMark

に達

したことを意味しますので、データの追加を中止しなければなりません。

generateRandom.js

という名前の新しいモジュールを作り、この中で

RandomStream

の新しいオ

ブジェクトをインスタンス化して、そこからデータを取得します（

07_streams_readable

）。

const RandomStream = require('./randomStream');

const randomStream = new RandomStream();

rando

mStream.on('readable', () => {

let chunk;

while((chunk = randomStream.read()) !== null) {

console.log(`Chunk received: ${chunk.toString()}`);

}

});

これですべての準備が整ったので、このストリームを試してみましょう。これまでと同じようにモ

ジュール

generateRandom

を実行し、ランダムな文字列が画面上に流れるのを確認してください。

5.2.3