Readable.read()をProxyオブジェクトでトラップする

fs_sample_main2.js

var fs = require('fs');
var doSomethingWithTheStream = require('./dosomething');

// readable streamはcreateReadStream関数がインスタンス化する
var readable = fs.createReadStream('image.jpg');

var totalBytes = 0;

// readableのメンバー関数read()をProxyで置き換え
readable.read = new Proxy(readable.read, {
  apply: (target, thisArg, argumentsList) => {
    // 元の関数(read)の呼び出し
    var bytes =  target.apply(thisArg, argumentsList);  
    // 戻り値を使う
    if (bytes) totalBytes += bytes.length;
    return bytes;
  }
});

// 「何か」をする関数にオブジェクトを渡す
doSomethingWithTheStream(readable).then(() => {
  console.log('All data read! = ' + totalBytes);
});