Node.js fs. Как можно в потоке модифицировать данные?

Question

[Виталий]

Всем доброго дня, суть пблемы следующая, проводил разбор бигдаты и пушил данные в файл, забыл, что объекты json надо бы разделять между собой запятой, написал сие костыли:

let fs = require('fs');
let writer = fs.createWriteStream('data_valid.json', {flags: 'w'});
let reader = fs.createReadStream('data.json',
    {
        flags: 'r',
        encoding: 'utf8'
    });
writer.on('finish', function () {
    console.error('Запись выполнена успешно.');
});


reader.on('readable', function() {
    let buf;
    while ((buf = reader.read()) !== null) {

        writer.write(buf+',');

    }
});

Все бы хорошо, все объекты один за другим попадают в buf, но не происходит buf+','
Что я делаю не так?
Буду признателен за пояснения.

Answer 1

[Владимир]

А хочу спросить в чем проблема просто копировать файл, вы же ничего более не делаете.

Comments

[Виталий]

writer.write(buf+','); серьезно?

[Владимир]

Виталий: че ты мне то пишешь?)

[Виталий]

Владимир: именно тебе и пишу. Показываю , что поток перебираю и запятые туда просовываю. Уже иначе решил вопрос, но ясности с потоком не пришло. Если есть что сказать по существу, говори, буду благодарен.

Answer 2

[Дмитрий Беляев]

Вы не завершаете поток записи и даже не флушаете его на диск, все данные остаются в оперативке и дохнут вместе с процессом
reader.on('end', () => writer.end());

Comments

[Виталий]

Даже не смотря на то что они пишутся? У меня суть вопроса в том, что я с буфером ничего сделать не могу, любая конкатенация игнорируется.