Node.js & Libuv•Part 3: Streams, Buffers & Core Modules (21 - 35)
Custom Transform Stream implementation.
In Simple Words:
Extend Transform and implement the _transform method:
javascript
const { Transform } = require('stream');
class CSVToJsonTransform extends Transform {
_transform(chunk, encoding, callback) {
const lines = chunk.toString().split('
');
const jsonLines = lines.map(line => JSON.stringify(line.split(',')));
this.push(jsonLines.join('
'));
callback();
}
}