|
|
@ -61,12 +61,12 @@ describe('PapaParse', function() { |
|
|
|
|
|
|
|
|
|
|
|
it('piped streaming CSV should be correctly parsed', function(done) { |
|
|
|
it('piped streaming CSV should be correctly parsed', function(done) { |
|
|
|
var data = []; |
|
|
|
var data = []; |
|
|
|
fs.createReadStream(__dirname + '/long-sample.csv', 'utf8') |
|
|
|
var readStream = fs.createReadStream(__dirname + '/long-sample.csv', 'utf8'); |
|
|
|
.pipe(Papa.parse(Papa.NODE_STREAM_INPUT)) |
|
|
|
var csvStream = readStream.pipe(Papa.parse(Papa.NODE_STREAM_INPUT)); |
|
|
|
.on('data', function(item) { |
|
|
|
csvStream.on('data', function(item) { |
|
|
|
data.push(item); |
|
|
|
data.push(item); |
|
|
|
}) |
|
|
|
}); |
|
|
|
.on('end', function() { |
|
|
|
csvStream.on('end', function() { |
|
|
|
assert.deepEqual(data[0], [ |
|
|
|
assert.deepEqual(data[0], [ |
|
|
|
'Grant', |
|
|
|
'Grant', |
|
|
|
'Dyer', |
|
|
|
'Dyer', |
|
|
|