Я решил эту проблему, используя модуль split npm . Труба вашего потока в раскол, и это будет « Разбить поток и собрать его так, чтобы каждая строка была фрагментом ».
Пример кода:
var fs = require('fs')
, split = require('split')
;
var stream = fs.createReadStream(filePath, {flags: 'r', encoding: 'utf-8'});
var lineStream = stream.pipe(split());
linestream.on('data', function(chunk) {
var json = JSON.parse(chunk);
// ...
});