Node.js میں streams کیا ہیں اور آپ انہیں کب استعمال کریں؟

Question

Accepted Answer

**Streams** ڈیٹا کو **بتدریج، chunks میں** پروسیس کرتے ہیں، بجائے اس کے کہ سب کو ایک بار میں میموری میں لوڈ کریں۔ یہ بڑے ڈیٹا (بڑی فائلوں، نیٹ ورک منتقلی) کے لیے ضروری ہے جہاں ہر چیز کو بفر کرنا میموری ختم کر دے۔

## 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 کے ساتھ، میموری کا استعمال فائل کی سائز سے قطع نظر فلیٹ رہتا ہے — آپ ایک وقت میں ایک chunk کو سنبھالتے ہیں۔

## چار stream کی اقسام

```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 — صحیح error handling کے ساتھ 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` chained `.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.
```

## یہ کیوں اہم ہے

Streams بڑے یا جاری ڈیٹا کی **میموری سے موثر** ہینڈلنگ کے لیے Node کی وضاحتی خصوصیت ہے — ایک بڑی اپ لوڈ پر کریش ہونے والی ایپ اور جو کسی بھی سائز کو فلیٹ میموری کے ساتھ سنبھالے اس میں فرق۔

چار stream کی اقسام، `pipe`/`pipeline` کمپوزیشن (اور `pipeline` محفوظ کیوں ہے) اور HTTP درخواستیں/جوابات جو خود streams ہیں، سب کو سمجھنا Node میں scalable file-handling، data-processing، اور proxying سروسز بنانے کے لیے ضروری ہے۔