Split stream for Node.js >= 4.x

splitStream.js

var stream = require('stream')

module.exports = split

function split(delim, emitTrailingIfEmpty) {
  delim = delim || new Buffer('\n')
  var trailing, delimLen = delim.length
  return new stream.Transform({
    readableObjectMode: true,
    transform: function(chunk, enc, cb) {
      var ix, offset = 0, firstOffset = trailing ? trailing.length : 0
      if (firstOffset) chunk = Buffer.concat([trailing, chunk])
      while ((ix = chunk.indexOf(delim, offset || firstOffset)) != -1) {
        this.push(chunk.slice(offset, ix))
        offset = ix + delimLen
      }
      trailing = offset ? chunk.slice(offset) : chunk
      cb()
    },
    flush: function(cb) {
      if (trailing && (trailing.length || emitTrailingIfEmpty)) this.push(trailing)
      cb()
    },
  })
}