Node Read/Write Streams

gistfile1.txt

  sanitizeFile: function(reportFile, columnAdditions, rowDeletions, callback, retryCount) {
    var rs = fs.createReadStream(reportFile, { encoding:'utf8' })
      , outputFile = path.dirname(reportFile) + "/" + path.basename(reportFile) + ".sanitized"
      , ws = fs.createWriteStream(outputFile);
      
     rs.on('data', function(data) {
        var flushed = ws.write(data);
        if (!flushed) { rs.pause(); }
     });
     
     rs.on('end', function() {
       callback(reportFile);       
     });
     
     ws.on('drain', function() {
       rs.resume();
     })
  }