Questions
5 of 24
How can you create a custom Transform stream in Node.js?
Difficulty: 5/10
Node.js streams, Transform API, Backpressure handling
By extending the Transform class from the stream module and implementing the _transform method to define how data should be transformed.
You can define a class that extends the class and implement the method to specify how the data is transformed.
You can now use your custom Transform stream by piping data through it:
The _transform(chunk, encoding, callback) method:
- 1
Handles the transformation logic for each chunk of data.
- 2
chunk is the current piece of data being transformed.
- 3
callback is called when the transformation is complete.
The _flush(callback) method:
- 1
Optional: It allows you to perform any cleanup or final transformations when the stream ends.
Scenario Questions
0-2 years experience
- 1Write a Transform stream that converts incoming text data to uppercase and explain how you'd wire it between a file read stream and a write stream.
- 2If you pipe a large file through your custom Transform and then to a writable, what does Node do when the internal buffer fills up?
- 3How would you modify your Transform to emit an error if it encounters a non‑string chunk?
2-5 years experience
- 1We need a Transform that parses newline‑delimited JSON from a TCP socket and emits JavaScript objects, skipping malformed lines; describe your implementation and error handling approach.
- 2A teammate's Transform stream is causing memory usage to climb over time; what are common causes and how would you debug the issue?
- 3Explain the trade‑offs of using objectMode versus binary mode for a logging pipeline that adds timestamps to each log entry.
5-8 years experience
- 1Design a streaming pipeline that reads CSV files, transforms each row, and writes to a database; where do you place custom Transform streams and how do you ensure backpressure flows end‑to‑end?
- 2Your service processes high‑throughput video chunks with a Transform that re‑encodes data; what performance considerations and stream options would you tune?
- 3If you must hot‑swap a Transform implementation in a running microservice without dropping data, how would you orchestrate the change safely?
8+ years experience
- 1Our legacy monolith uses callback‑based file processing; we want to migrate to a modern stream‑based architecture with shared custom Transform streams across teams. How would you plan the migration, define stable interfaces, and avoid breaking existing contracts?
- 2When multiple services depend on a common Transform library, what versioning and compatibility strategies would you enforce to prevent runtime errors at scale?
- 3Consider a requirement to enforce PII redaction across all data flows using a Transform stream. How would you architect a reusable, auditable component that can be injected globally while meeting regulatory compliance?
Follow-up Questions
- What would happen if you forget to call the callback in _transform?
- How does your Transform behave when the downstream consumer is slower than the source?
- Can you show how you'd test error handling in this stream?