Τι είναι τα streams στο Node.js και πότε θα πρέπει να τα χρησιμοποιείς;

Question

Accepted Answer

**Streams** επεξεργάζονται δεδομένα **βαθμιαία, σε κομμάτια**, αντί να φορτώνουν όλα τα δεδομένα στη μνήμη ταυτόχρονα. Αυτό τα κάνει απαραίτητα για μεγάλα δεδομένα (μεγάλα αρχεία, μεταφορές δικτύου) όπου η αποθήκευση όλων στην προσωρινή μνήμη θα εξάντλαγε τη μνήμη.

## Το πρόβλημα που λύνουν τα streams

```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"));
```

Με τα streams, η χρήση μνήμης παραμένει σταθερή ανεξάρτητα από το μέγεθος του αρχείου — χειρίζεσαι ένα κομμάτι κάθε φορά.

## Τα τέσσερα είδη streams

```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 — σύνδεση streams

```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` συνδέει ένα readable με ένα writable (με transforms ενδιάμεσα), διαχειρίζεται αυτόματα τη ροή — ο συνηθισμένος τρόπος σύνθεσης streams.

## pipeline — pipe με σωστή διαχείριση σφαλμάτων

```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` προτιμάται έναντι των αλυσιδωτών `.pipe()` επειδή διαδίδει σφάλματα και καθαρίζει σωστά κάθε stream.

## Που εμφανίζονται τα streams

```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
```

## Πότε να μη ασχολείσαι

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

## Γιατί έχει σημασία

Tα streams είναι ένα χαρακτηριστικό Node για την **αποδοτική χρήση μνήμης** κατά την επεξεργασία μεγάλων ή συνεχών δεδομένων — η διαφορά μεταξύ μιας εφαρμογής που κάνει crash σε μια μεγάλη μεταφόρτωση και μιας που χειρίζεται οποιοδήποτε μέγεθος με σταθερή μνήμη.

Ο κατανόηση των τεσσάρων ειδών, της σύνθεσης `pipe`/`pipeline` (και γιατί `pipeline` είναι ασφαλέστερο), και ότι τα HTTP requests/responses είναι από μόνα τους streams, είναι ουσιαστικό για την κατασκευή επεκτάσιμων υπηρεσιών χειρισμού αρχείων, επεξεργασίας δεδομένων και proxy στο Node.