Explain the concept of object streams and provide an example use case.

Q: Explain the concept of object streams and provide an example use case.

const { Readable, Transform, Writable } = require('stream'); // Example: Array of user objects const users = [ { id: 1, name: 'Alice' }, { id: 2, name: 'Bob' }, { id: 3, name: 'Charlie' } ]; // Readable stream: Emits user objects const readableStream = Readable.from(users, { objectMode: true }); // Transform stream: Modifies the user object const transformStream = new Transform({ objectMode: true, transform(user, encoding, callback) { user.name = user.name.toUpperCase(); // Transforming the name to uppercase this.push(user); // Push the transformed object callback(); // Indicate the transformation is done } }); // Writable stream: Consumes the transformed objects const writableStream = new Writable({ objectMode: true, write(user, encoding, callback) { console.log(`Processed User:`, user); // Output the final user object callback(); } }); // Pipe the streams together readableStream.pipe(transformStream).pipe(writableStream); Data Transformation Pipelines: Converting data formats (e.g., JSON to CSV). Normalizing data (e.g., modifying or restructuring object properties). Logging Systems: Streaming log entries as structured objects for storage or analysis Database Operations: Streaming objects from a database query and transforming or processing them before writing them to another source.

Difficulty: 5/10

objectMode, pipeline, back‑pressure

By default, Node.js streams deal with Buffer or string data, but object streams make it easier to handle structured data, such as JSON objects, arrays, or even complex custom objects.

To create or use an object stream, the objectMode property must be set to when creating a stream. This enables the stream to work with JavaScript objects rather than just bytes or characters.

Example Use Cases

1
Data Transformation Pipelines: Converting data formats (e.g., JSON to CSV). Normalizing data (e.g., modifying or restructuring object properties).
2

Explain the concept of object streams and provide an example use case.

By default, Node.js streams deal with Buffer or string data, but object streams make it easier to handle structured data, such as JSON objects, arrays, or even complex custom objects.

Scenario Questions

Follow-up Questions