const { Readable, Writable, Transform } = require('stream');
const objectReadable = new Readable({
objectMode: true,
read() {}
});
const objectTransform = new Transform({
objectMode: true,
transform(chunk, encoding, callback) {
chunk.transformed = true;
chunk.timestamp = new Date();
this.push(chunk);
callback();
} });
const objectWritable = new Writable({
objectMode: true,
write(chunk, encoding, callback) {
console.log('Received object:', chunk);
callback();
} });
objectReadable
.pipe(objectTransform)
.pipe(objectWritable);
objectReadable.push({ name: 'Object 1', value: 10 });
objectReadable.push({ name: 'Object 2', value: 20 });
objectReadable.push({ name: 'Object 3', value: 30 });
objectReadable.push(null);