Transform streams for processing in Node.js - Mini Project: Build & Apply

Transform Streams for Processing Data in Node.js

📖 Scenario: You are building a simple Node.js program that reads text data, processes it by converting all letters to uppercase, and outputs the transformed data. This simulates a real-world task like processing user input or file content before saving or sending it.

🎯 Goal: Create a Node.js transform stream that converts input text to uppercase and outputs the transformed text.

📋 What You'll Learn

Create a readable stream with sample text data

Create a transform stream that converts text to uppercase

Pipe the readable stream through the transform stream

Output the transformed data to the console

💡 Why This Matters

🌍 Real World

Transform streams are used in Node.js to process data on the fly, such as modifying file contents, compressing data, or filtering input before saving or sending it.

💼 Career

Understanding transform streams is important for backend developers working with data processing, file handling, and building efficient network applications.

1

Create a readable stream with sample text

Create a constant called Readable by requiring 'stream' module. Then create a readable stream called inputStream using Readable.from with the array ['hello', ' ', 'world'].

Node.js

const { Readable } = require('stream');
// Create inputStream from array ['hello', ' ', 'world']
// Your code here

Need a hint?

Use Readable.from to create a stream from an array of strings.

2

Create a transform stream to convert text to uppercase

Create a constant called Transform by requiring 'stream' module. Then create a transform stream called upperCaseTransform using new Transform with a transform function that converts the chunk to uppercase string and pushes it.

Node.js

const { Readable, Transform } = require('stream');
const inputStream = Readable.from(['hello', ' ', 'world']);
// Create upperCaseTransform stream that converts chunks to uppercase
// Your code here

Need a hint?

Use the transform method to change each chunk to uppercase and push it forward.

3

Pipe the readable stream through the transform stream

Use inputStream.pipe(upperCaseTransform) and assign the result to a constant called outputStream.

Node.js

const { Readable, Transform } = require('stream');
const inputStream = Readable.from(['hello', ' ', 'world']);

const upperCaseTransform = new Transform({
  transform(chunk, encoding, callback) {
    this.push(chunk.toString().toUpperCase());
    callback();
  }
});

// Pipe inputStream through upperCaseTransform and assign to outputStream
// Your code here

Need a hint?

Use the pipe method to connect streams.

4

Output the transformed data to the console

Add a data event listener on outputStream that receives chunk and writes it to process.stdout.

Node.js

const { Readable, Transform } = require('stream');
const inputStream = Readable.from(['hello', ' ', 'world']);

const upperCaseTransform = new Transform({
  transform(chunk, encoding, callback) {
    this.push(chunk.toString().toUpperCase());
    callback();
  }
});

const outputStream = inputStream.pipe(upperCaseTransform);

// Add data event listener on outputStream to write chunks to process.stdout
// Your code here

Need a hint?

Listen for data events on the output stream and write each chunk to the console.