Working with Node.js Streams

Streams process chunks instead of loading an entire input into memory. Node Readable streams support asynchronous iteration; text can be decoded chunk by chunk. Stream consumers must consider backpressure, errors, and chunk boundaries when parsing structured data.

Readable.from creates a stream of three known chunks. The async iterator waits for each chunk and appends its text. Production file streams can emit arbitrary chunk sizes; never assume a chunk equals one line.

Do not use an unbounded string accumulator when the goal is to handle a huge file in constant memory.

Save as working-node-js-streams.ts. The following program passed strict TypeScript compilation, and the displayed output was captured by executing its emitted JavaScript with Node.js 22.16.0.

TypeScript source

import { Readable } from "node:stream";
async function main(): Promise<void> {
  const source = Readable.from(["Type", "Script", " works"]);
  let result = "";
  for await (const chunk of source) result += String(chunk);
  console.log(result);
}
main().catch(console.error);

Verified output

TypeScript works

Compile: npx tsc --strict --target es2022 --module commonjs working-node-js-streams.ts; run: node working-node-js-streams.js. For Node.js API examples, install @types/node first. For browser projects, use the browser-specific instructions below.

The example runs in Node.js 22.16.0; if it reads runtime environment details, your displayed values may differ.

Readable.from creates a stream of three known chunks. The async iterator waits for each chunk and appends its text. Production file streams can emit arbitrary chunk sizes; never assume a chunk equals one line.

Predict what changes if you alter one input. Then run the code to compare your reasoning with the real output.

Do not use an unbounded string accumulator when the goal is to handle a huge file in constant memory.

Identify whether the failure is a type-checking issue, a configuration issue, or a runtime behavior issue before choosing a fix.

Stream a temporary text file using createReadStream and count newline characters while reading.

Write down your expected result first. For configuration examples, compare compiler output and diagnostics; for test examples, make the assertion fail deliberately to verify that the tool reports it.

Streams process chunks instead of loading an entire input into memory.

Run the primary example, then complete the practice task or environment-specific lab.