pause node walkdir, read a file into a write stream, then resume

pauseresume_walkdir.js

// walkdir ~0.0.5
var fs = require('fs')
, walkdir = require('../walkdir')
// write all logs to the logs.cat file
, ws = fs.createWriteStream('logs.cat')
;

var em = walkdir('./');

em.on('file',function(path,stat){

  if(path.indexOf('.log') != path.length-4) return;

  em.pause();

  var rs = fs.createReadStream(path);

  rs.on('end',function(){
    em.resume();
  });

  rs.on('data',function(buf){
    ws.write(buf);
  });
});

em.on('end',function(){
  console.log('done!');
});