Kas yra srautai (streams) Node.js ir kada jūs turėtumėte juos naudoti?

Question

Accepted Answer

**Srautai** apdoroja duomenis **nuosekliai, dalimis**, o ne įkėlę viską į atmintį iš karto. Tai atsiskaitingai svarbų dideliems duomenims (didelės bylos, tinklo perdavimas), kur visų buferinimas būtų išnaudojęs atmintį.

## Problema, kurią sprendžia srautai

```js
// ❌ loads the ENTIRE file into memory — crashes on a 10GB file
const data = await fs.promises.readFile("huge.csv");
process(data);

// ✅ stream it — constant memory, processes chunk by chunk
fs.createReadStream("huge.csv")
  .pipe(transform)
  .pipe(fs.createWriteStream("out.csv"));
```

Su srautais atmintis išlieka stabili, nepaisant bylos dydžio — jūs tvarkote vieną dalį vienu metu.

## Keturi srauto tipai

```text
Readable  → source you read FROM (fs.createReadStream, http request)
Writable  → destination you write TO (fs.createWriteStream, http response)
Duplex    → both readable & writable (TCP socket)
Transform → modify data as it passes through (zlib gzip, encryption)
```

## pipe — sujungti srautus

```js
import { createReadStream, createWriteStream } from "fs";
import { createGzip } from "zlib";

// read → compress → write, all streaming, low memory
createReadStream("file.txt")
  .pipe(createGzip())            // Transform: compress on the fly
  .pipe(createWriteStream("file.txt.gz"));
```

`pipe` sujungia skaitomą srautą su rašomu (su transformacijomis tarp jų), automatiškai valdydamas srautą — idiominis būdas srautus sukomponuoti.

## pipeline — pipe su tinkamu klaidų valdymu

```js
import { pipeline } from "stream/promises";

await pipeline(
  createReadStream("in.txt"),
  createGzip(),
  createWriteStream("out.gz")
); // ✅ cleans up all streams on error/completion (pipe alone leaks on errors)
```

`pipeline` yra geriau nei segtiniai `.pipe()` nes jis platina klaidas ir tinkamai valosi kiekvieną srautą.

## Kur srautai pasirodo

```text
✓ HTTP request/response bodies (req and res ARE streams)
✓ File reading/writing, file uploads/downloads
✓ Compression (zlib), encryption (crypto)
✓ Database cursors, large query results
✓ Real-time data processing, video streaming
```

## Kada to nevargu

```text
Small data that fits comfortably in memory → readFile/simple buffering is simpler.
Streams add complexity; use them for LARGE or continuous data.
```

## Kodėl tai svarbu

Srautai yra apibrėžiantis Node savumas **atmintimi efektyviam** didelių ar tęstinių duomenų tvarkymui — skirtumas tarp programos, kuri sugriūva dėl didelio įkėlimo, ir tos, kuri valčia bet kokį dydį su stabilia atmintimi.

Supratimas keturių tipų, `pipe`/`pipeline` sukomponavimo (ir kodėl `pipeline` saugesnis) ir tai, kad HTTP užklausos/atsakymai patys yra srautai, yra esmingas didinamam bylos tvarkymo, duomenų apdorojimo ir tarpininkavimo paslaugų statymuisi Node aplinkoje.