split.js

var PullStream = require('./pull');

var SplitStream = PullStream.extend({
  constructor: function SplitStream(source, pattern) {
    PullStream.call(this, source);
    this._pattern = pattern || /\r\n|\r|\n/;
    this._buffered = '';
  },

  _process: function(chunk) {
    var match, line;

    this._buffered += chunk;

    while (match = this._pattern.exec(this._buffered)) {
      line = this._buffered.slice(0, match.index);
      this._buffered = this._buffered.slice(match.index + match[0].length);
      this._forward(line);
    }
  }
});


module.exports = function split(pattern) {
  return new SplitStream(this, pattern);
};