Node.js मा streams के हुन् र कहिले तपाईले तिनलाई प्रयोग गर्नुपर्छ?

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 को साथ, मेमोरी उपयोग फाइल साइज को निर्विशेष सपाट रहन्छ — तपाई एक पटकमा एक चङ्क हेर्नुहुन्छ।

## चार 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 — उचित त्रुटि हेरफेरको साथ 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 को परिभाषित विशेषता हो — एक अनुप्रयोग जो ठूलो अपलोडमा क्र्यास हुन्छ र एक जो कुनै आकारको साथ सपाट मेमोरी हेर्न सक्छ को बीचको अन्तर।

चार प्रकार, `pipe`/`pipeline` समन्वय (र किन `pipeline` अधिक सुरक्षित छ), र HTTP अनुरोध/प्रतिक्रियाहरू स्वयं streams हुन् भनी बुझ्नु Node मा स्केलेबल फाइल-हेरफेर, डेटा-प्रक्रिया, र प्रॉक्सिङ सेवाहरू निर्माण गर्नको लागि आवश्यक छ।