Creates a transform stream that splits any stream pipped into it into lines.

line-splitter.js

var stream = require("stream"),
    util = require("util");

var LineSplitter = function LineSplitter(options) {
  options = options || {};
  options.objectMode = true;
  stream.Transform.call(this, options);
  this.buffer = "";
};
util.inherits(LineSplitter, stream.Transform);

LineSplitter.prototype._transform = function _transform(input, encoding, done) {
  this.buffer += input.toString(encoding);

  var lines = this.buffer.split(/\n/g);
  this.buffer = lines.pop();

  lines.forEach(this.push.bind(this));

  return done();
};

//usage

splitter = new lineSplitter()
someFile.pipe(splitter).pipe(someDestination)