batch-stream-csv
Advanced tools
Comparing version 1.0.1 to 1.0.2
@@ -10,8 +10,7 @@ const csv = require('csv-parser') | ||
return new Promise((resolve, reject) => { | ||
let rows = [] | ||
const rows = [] | ||
const rs = fs.createReadStream(file) | ||
rs | ||
.pipe(csv(options)) | ||
.on('headers', function processHeaders (headers) { | ||
.on('headers', function processHeaders () { | ||
read += this.state.rowLength | ||
@@ -26,3 +25,3 @@ }) | ||
if (rows.length) await flush() | ||
resolve() | ||
resolve() | ||
}) | ||
@@ -29,0 +28,0 @@ |
{ | ||
"name": "batch-stream-csv", | ||
"version": "1.0.1", | ||
"version": "1.0.2", | ||
"description": "Process large CSV files in batches without backpressure", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
6211