Backpressure en piping
Beheer flow control met pipeTo en pipeThrough.
Backpressure en piping is een gratis JavaScript Academy-les op CoddyKit. Dit is les 4 van 4. Je kunt 3 lessen uit dit leerpad gratis volledig lezen — daarna ontgrendelt CoddyKit PRO alle lessen, plus praktische oefeningen met een ingebouwde code-editor en een AI-tutor die 24/7 beschikbaar is. Deze les maakt deel uit van het leertraject JavaScript Academy. Je voortgang wordt gesynchroniseerd op het web en in de CoddyKit-app. De cursus JavaScript Academy bevat in totaal 4 lessen.
Het backpressureprobleem
Als een producent sneller gegevens genereert dan een consument ze kan verwerken, raakt het geheugen vol. Backpressure is het mechanisme waarmee een trage consument een snelle producent vertelt dat die moet vertragen.
WritableStream
Een WritableStream is een bestemming waar je delen naartoe schrijft. De sink-methode write(chunk) kan asynchroon zijn en aangeven wanneer het volgende deel klaar is.
const sink = new WritableStream({
write(chunk) {
console.log("writing", chunk);
}
});Een schrijver ophalen
getWriter() vergrendelt de schrijfbare stream en retourneert een schrijver met write(), close() en een ready-promise.
const writer = sink.getWriter();
await writer.write("hello");
await writer.close();Het ready-signaal
Wacht met await op writer.ready voordat je schrijft. De promise wordt vervuld wanneer de stream meer gegevens kan accepteren — zo werkt backpressure in de praktijk.
await writer.ready;
await writer.write(chunk);pipeTo
readable.pipeTo(writable) verbindt een bron met een bestemming en beheert backpressure automatisch voor je. De methode retourneert een promise die wordt vervuld wanneer het doorsturen is voltooid.
await readableStream.pipeTo(writableStream);
console.log("done piping");pipeThrough
pipeThrough(transform) voegt een transformatie toe tussen bron en bestemming en retourneert de getransformeerde leesbare stream. Koppel er meerdere om een pijplijn te bouwen.
sourceStream
.pipeThrough(new TextDecoderStream())
.pipeThrough(parser)
.pipeTo(consumer);Hoge watermarkeringen
De highWaterMark van een wachtrijstrategie bepaalt hoeveel delen in de wachtrij mogen staan voordat backpressure actief wordt. Stem deze waarde af om verwerkingssnelheid en geheugengebruik in balans te houden.
new ReadableStream(source, new CountQueuingStrategy({ highWaterMark: 4 }));desiredSize
desiredSize van een controller vertelt de producent hoeveel ruimte er nog in de wachtrij is. Zodra de waarde nul of lager wordt, moet je stoppen met toevoegen aan de wachtrij.
pull(controller) {
while (controller.desiredSize > 0) {
controller.enqueue(nextChunk());
}
}Een pijplijn afbreken
Geef { signal } door aan pipeTo om de hele pijplijn af te breken met een AbortController.
const ctrl = new AbortController();
readable.pipeTo(writable, { signal: ctrl.signal });
ctrl.abort();Opties voor doorsturen
pipeTo accepteert preventClose, preventAbort en preventCancel om te bepalen hoe fouten en voltooiing tussen beide uiteinden worden doorgegeven.
readable.pipeTo(writable, { preventClose: true });Een volledige pijplijn
Alles samen: bytes ophalen, decoderen, transformeren en naar een bestemming schrijven — allemaal met automatische stroomregeling.
const res = await fetch("/data");
await res.body
.pipeThrough(new TextDecoderStream())
.pipeThrough(lineSplitter)
.pipeTo(uiSink);Korte controle
Test backpressure.
Samenvatting: backpressure en doorsturen
Je hebt WritableStream en schrijvers leren kennen, met ready gewacht op backpressure, streams verbonden met pipeTo/pipeThrough, highWaterMark afgestemd en desiredSize in de gaten gehouden, en pijplijnen afgebroken. Daarmee is de Streams API voltooid.
Leer JavaScript met een AI-tutor — gratis
Schrijf echte code en voer die uit in je browser, krijg direct hulp van een AI-tutor die 24/7 beschikbaar is en ga verder waar je gebleven bent op het web of in de app.
- Cursussen
- 59
- Lessen
- 200
Veelgestelde vragen
Is de les “Backpressure en piping” gratis?
Ja — je kunt hier op het web alle 3 lessen van het leerpad JavaScript Academy, waaronder “Backpressure en piping”, gratis volledig lezen. Daarna ontgrendelt CoddyKit PRO alle lessen, plus interactieve oefeningen met een ingebouwde code-editor en een AI-tutor die 24/7 beschikbaar is. De cursus JavaScript Academy bevat in totaal 4 lessen.
Wat leer ik in “Backpressure en piping”?
Beheer flow control met pipeTo en pipeThrough. Je oefent met JavaScript Academy door code rechtstreeks in de browser uit te voeren. Een AI-begeleider die 24/7 beschikbaar is beantwoordt je vragen terwijl je de les doorwerkt.
Heb ik ervaring nodig om met JavaScript Academy te beginnen?
Ervaring vooraf is niet nodig. JavaScript Academy op CoddyKit is opgebouwd voor beginners tot gevorderden, zodat je hier of bij het begin kunt starten en in je eigen tempo kunt leren. Dit is les 4 van 4.
Hoe lang duurt de les “Backpressure en piping”?
De meeste lessen van CoddyKit duren ongeveer 5–10 minuten. Elke les is kort en interactief, zodat je gestaag vooruitgaat en op het web en in de app precies verdergaat waar je was gebleven.
Kan ik code schrijven en uitvoeren in deze les over JavaScript Academy?
Ja. Elke les over JavaScript Academy bevat een ingebouwde code-editor, zodat je rechtstreeks in je browser echte code kunt schrijven en uitvoeren en direct feedback van AI krijgt — lokale installatie is niet nodig.
Alle lessen in deze cursus
- Leesbare streams
- Streaming-fetch-responses
- Transform Streams
- Backpressure en piping