Method _transform

src/index.js:350–396

(chunk, encoding, next)

  }

  _transform(chunk, encoding, next) {
    // decode binary chunks as UTF-8
    encoding = encoding || 'utf8';

    if (Buffer.isBuffer(chunk)) {
      if (encoding === 'buffer') {
        encoding = 'utf8';
      }
      chunk = chunk.toString(encoding);
    }

    this.lineBuffer += chunk;

    if (!containsLineEnd(chunk)) {
      next();
      return;
    }

    const lines = this.lineBuffer.match(this.re);
    if (!lines || lines.length === 0) {
      next();
      return;
    }

    // Do not split CRLF which spans chunks
    if (this.state.lastChunkEndedWithCR && lines[0] === '\n') {
      lines.shift();
    }

    this.state.lastChunkEndedWithCR = (this.lineBuffer[this.lineBuffer.length - 1] === '\r');

    if ((this.lineBuffer[this.lineBuffer.length - 1] === '\r') ||
      (this.lineBuffer[this.lineBuffer.length - 1] === '\n')) {
      this.lineBuffer = '';
    } else {
      const line = lines.pop() || '';
      this.lineBuffer = line;
    }

    iterateArray(lines, { batchSize: this.options.batchSize }, (line) => {
      line = line.trim();
      if (line.length > 0) {
        const result = parseLine(line, this.options);
        this.push(result);
      }
    }, next);
  }

  _flush(done) {
    if (this.lineBuffer) {