Readable streamを使って、「何か」をする関数の本体

dosomething.js

// readableを使って「何か」をする関数の本体
module.exports = function doSomethingWithTheStream(readable) {
  return new Promise(function(resolve, reject){
   
    var count = 0;
    readable.on('readable', () => {
      // 読み取り
      var data;
      while (data = readable.read()) {
        // ここで読み取った部分的なデータ(chunk)を処理する...
        console.log(`do something using read data from stream: cycle=${count++}`);
      }
    });

    readable.on('end', () => {
      // streamの最後に到達したら、resolveで処理を完了する
      resolve();
    });
  });
}