'use strict';

const fs = require('node:fs');

const stream = require('node:stream');

const readable = fs.createReadStream('data.tmp');

const writable = new stream.Writable({

write(chunk, encoding, next) {

console.log({ size: chunk.length, encoding, next });

//next(new Error('Error flushing data'));

next();

},

});

readable.pipe(writable);

readable.on('end', () => {

console.log('Done');

});