gistfile1.txt

var CSV = require('csv');

CSV()
  .from.string('foo\nbar\nbaz')
  .on('record', function(row, index) {
    if (index === 2) {
      this.error(new Error('stop'));
    }
  })
  .on('error', function(err) {
    console.log(err);
  })
  .on('end', function(count) {
    console.log('end');
  });