Node.js
pipe
.pipe ile stream'leri bağlamayı öğrenirsin.
pipe
pipe metodu bir Readable'ı bir Writable'a bağlar; veri otomatik akar. İmza: readable.pipe(writable). Böylece "data" ve write çağrılarını elle yazmazsın; pipe hepsini yönetir.
Örnek: kaynak.pipe(hedef). Kaynaktan gelen her parça otomatik olarak hedefe yazılır; akış bittiğinde hedefin end()'i çağrılır ve "finish" olayı fırlar. pipe aynı zamanda geri basınç (backpressure) denetler: hedef yavaşsa kaynak bekler. Bu, veriyi kaynaktan hedefe güvenle taşımanın en kısa yoludur.
pipe ile zincirleme
pipe hedef Writable'ı döndürür; bu yüzden zincirleme yapabilirsin. Özellikle Transform stream'lerle güçlüdür: kaynak.pipe(donusturucu).pipe(hedef). Veri önce dönüştürülür, sonra hedefe yazılır.
Basit bir zincir: const kaynak = Readable.from(["a", "b"]); const hedef = new Writable({ write(c, e, cb) { console.log("Pipe: " + c.toString()); cb(); } }); kaynak.pipe(hedef);. hedef.on("finish", () => console.log("Pipe bitti")) ile akışın tamamlandığını yakalarsın. pipe hedefi döndürdüğü için kaynak.pipe(hedef).on("finish", ...) de yazılabilir; bu, zincirleri kısa tutar.
Uygulama İki akışı pipe ile bağla
kaynak adında Readable.from(["a", "b", "c"]) oluştur. hedef adında bir Writable oluştur: write içinde "Pipe: " + chunk.toString() yazdır ve cb() çağır. kaynak.pipe(hedef) ile bağla. hedef.on("finish", ...) ile "Pipe bitti" yaz.
Örnek çözümü göster
const { Readable, Writable } = require("stream");
const kaynak = Readable.from(["a", "b", "c"]);
const hedef = new Writable({
write(chunk, enc, cb) { console.log("Pipe: " + chunk.toString()); cb(); }
});
kaynak.pipe(hedef);
hedef.on("finish", () => console.log("Pipe bitti"));
Kendini test et
-
kaynak.pipe(hedef) ne yapar?
kaynak.pipe(hedef)
- Hedefi siler
- Kaynaktan gelen parçaları otomatik hedefe yazar
- Yalnızca hedefin adını döndürür
- Kaynağı yeniden başlatır
Cevabı göster
Kaynaktan gelen parçaları otomatik hedefe yazar — pipe parçaları otomatik hedefe yazar.
-
Parçayı rolüne eşle
- pipe
- Akışları bağlar
- Readable
- Kaynak akışı
- Writable
- Hedef akışı
- "finish"
- Hedef tamamlandı
-
pipe çağrısını tamamla
kaynak.____(hedef);
Cevabı göster
kaynak.pipe(hedef);
Sıradaki ders: Transform stream
