summer4096 · February 18, 2015 22:07
diff --git a/evil.csv b/evil.csv
diff --git a/package.json b/package.json
 {
  "name": "test",
  "version": "0.0.0",
  "description": "",
  "main": "test.js",
  "license": "MIT",
  "dependencies": {
    "fast-csv": "^0.5.5",
    "through2": "^0.6.3"
  }
 }
diff --git a/test.js b/test.js
 var fs = require('fs')
  , csv = require('fast-csv')
  , through2 = require('through2');

 var rowCount = 0;

 fs.createReadStream('evil.csv', 'utf8')
  .pipe(csv({headers: true}))
  .pipe(through2.obj(function(chunk, enc, cb){
    rowCount++;

    if (rowCount%2 == 1) {
      setTimeout(cb, 10);
    } else {
      cb();
    }
  }));
	var fs = require('fs')
	, csv = require('fast-csv')
	, through2 = require('through2');

	var rowCount = 0;

	fs.createReadStream('evil.csv', 'utf8')
	.pipe(csv({headers: true}))
	.pipe(through2.obj(function(chunk, enc, cb){
	rowCount++;

	if (rowCount%2 == 1) {
	setTimeout(cb, 10);
	} else {
	cb();
	}
	}));