Piping Streams
.pipe(), METHOD, EK, READABLE, STREAM, ko, DIRECTLY, EK, WRITABLE, STREAM, se, CONNECT, karta hai — AUTOMATICALLY, DATA, FLOW, karta hai, aur, BACKPRESSURE, (jab, WRITABLE, STREAM, SLOW, hai) AUTOMATICALLY, HANDLE, ho, jaata hai.
Multiple, PIPES, CHAIN, kiye, ja, sakte, hain — jaise, READ, STREAM, se, COMPRESS, (Transform, STREAM) se, WRITE, STREAM, tak. YE, PATTERN, LARGE, FILE, PROCESSING, PIPELINES, banaне, ke, liye, POWERFUL, hai.
const fs = require("fs");
const zlib = require("zlib");
fs.createReadStream("input.txt")
.pipe(zlib.createGzip()) // compress
.pipe(fs.createWriteStream("input.txt.gz"));
// HTTP response, streaming (large file serve karна):
app.get("/download", (req, res) => {
fs.createReadStream("large-file.zip").pipe(res);
});- .pipe() = readable, stream, ko, writable, stream, se, DIRECTLY, connect, karta hai
- Backpressure, automatically, HANDLE, ho, jaata hai
- Multiple pipes, CHAIN, kiye, ja, sakte, hain (jaise, read → compress → write)
.pipe(), errors, ko, AUTOMATICALLY, PROPAGATE, NAHI, karta — HAR, STREAM, PAR, ALAG, se, "error" LISTENER, ATTACH, karna, PADТA, hai. pipeline() (stream module se), YE, PROBLEM, SOLVE, karta hai.
const { pipeline } = require("stream");
pipeline(
fs.createReadStream("in.txt"),
zlib.createGzip(),
fs.createWriteStream("in.txt.gz"),
(err) => { if (err) console.error("Pipeline failed:", err); }
);stream.pipeline(), ERRORS, ko, PROPERLY, PROPAGATE, karta hai, aur, SAARE, STREAMS, ko, AUTOMATICALLY, CLEANUP/DESTROY, kar, deta hai, AGAR, KOI, EK, FAIL, ho, jaaye — MEMORY, LEAKS, PREVENT, karta hai, JO, .pipe() chains, mein, ho, sakte, HAIN.