Node.jsで標準入力から大きなデータの入力を受ける

ok_pipe.js

process.stdin.resume();
process.stdin.setEncoding('utf8');

var fragment = "";
process.stdin.on('data', function(chunk){
  if (chunk == "") { return ;}
  var lines = chunk.split("\n");
  lines[0] = fragment + lines[0];
  fragment = lines.pop();
  lines.forEach(function(line){
    // なんか処理する
  });
});
 
// ストリーム終了時に呼ばれる.
process.stdin.on('end', function(){
  
});