ReadableStreamDefaultController: enqueue()-Methode

Baseline Weitgehend verfügbar

Diese Funktion ist gut etabliert und funktioniert auf vielen Geräten und in vielen Browserversionen. Sie ist seit Januar 2020 browserübergreifend verfügbar.

Hinweis: Diese Funktion ist in Web Workers verfügbar.

Die enqueue()-Methode des ReadableStreamDefaultController-Interfaces fügt ein angegebenes Chunk in den zugehörigen Stream ein.

In diesem Artikel

Syntax

enqueue(chunk)

Parameter

chunk

Das Chunk, das eingefügt werden soll.

Wird ausgelöst, wenn enqueue() aufgerufen wird, während der Stream nicht lesbar ist, weil er bereits geschlossen, abgebrochen oder fehlerhaft ist, oder weil die zugrunde liegende Quelle gebeten hat, ihn zu schließen, dies aber noch nicht getan hat, da noch eingefügte Chunks zum Lesen vorhanden sind.

Beispiele

Im folgenden einfachen Beispiel wird ein benutzerdefinierter ReadableStream mithilfe eines Konstruktors erstellt (siehe unser Einfaches Beispiel für einen zufälligen Stream für den vollständigen Code). Die start()-Funktion erzeugt jede Sekunde einen zufällig generierten Textstring und fügt diesen in den Stream ein — siehe controller.enqueue(string). Eine cancel()-Funktion wird ebenfalls bereitgestellt, um die Erzeugung zu stoppen, wenn ReadableStream.cancel() aus irgendeinem Grund aufgerufen wird.

Wenn ein Button gedrückt wird, wird die Erzeugung gestoppt, der Stream wird mit ReadableStreamDefaultController.close() geschlossen, und eine andere Funktion wird ausgeführt, die die Daten erneut aus dem Stream liest.

js
let interval;
const stream = new ReadableStream({
  start(controller) {
    interval = setInterval(() => {
      let string = randomChars();

      // Add the string to the stream
      controller.enqueue(string);

      // show it on the screen
      let listItem = document.createElement("li");
      listItem.textContent = string;
      list1.appendChild(listItem);
    }, 1000);

    button.addEventListener("click", () => {
      clearInterval(interval);
      fetchStream();
      controller.close();
    });
  },
  pull(controller) {
    // We don't really need a pull in this example
  },
  cancel() {
    // This is called if the reader cancels,
    // so we should stop generating strings
    clearInterval(interval);
  },
});

Help improve MDN

War diese Übersetzung hilfreich?

Ja Nein

Erfahren Sie, wie Sie beitragen können Diese Seite wurde automatisch aus dem Englischen übersetzt.

Übersetzung auf GitHub anzeigen • Fehler mit dieser Übersetzung melden

Streams API
ReadableStreamDefaultController
Instanzeigenschaften
1. desiredSize
Instanzmethoden
Verwandte Seiten für Streams
Anleitungen
1. Streams API Konzepte
2. Verwendung von lesbaren Streams
3. Verwendung von lesbaren Bytestreams
4. Verwenden von beschreibbaren Streams

ReadableStreamDefaultController: enqueue()-Methode

In diesem Artikel

Syntax

Parameter

Rückgabewert

Ausnahmen

Beispiele

Spezifikationen

Browser-Kompatibilität

Siehe auch

Help improve MDN