Backpressure-Behandlung in asynchronen Generatoren

Snippet

Backpressure-Behandlung in asynchronen Generatoren

Asynchrone Generatoren bieten eine natürliche Möglichkeit, Backpressure zu implementieren. Indem man innerhalb des Generators vor dem 'yield' auf ein Promise wartet, signalisiert man dem Produzenten, dass der Konsument noch nicht bereit für weitere Daten ist, was die Flusssteuerung in asynchronen Strömen effizient verwaltet.

snippet.js
javascript
async function* streamProcessor(source) {
  for await (const chunk of source) {
    if (needsThrottling()) {
      await new Promise(r => setTimeout(r, 100)); // Simulate backpressure
    }
    yield transform(chunk);
  }
}
 
const consumer = async () => {
  for await (const data of streamProcessor(dataSource)) {
    console.log(data);
  }
};

Erklärung

async function* streamProcessor

Definiert einen Generator, der asynchrone Operationen zwischen den Yields abwarten kann.

for await (const chunk of source)

Konsumiert einen asynchronen Iterator unter Berücksichtigung seines Timings.

Vorheriges Snippet Nächstes Snippet

Verwandt

Aus deiner Bibliothek