ReadableStream: from() statische Methode

Syntax

ReadableStream.from(anyIterable)

Parameter

anyIterable

Ein iterierbares oder asynchron iterierbares Objekt.

Rückgabewert

Ein ReadableStream.

Ausnahmen

TypeError

Wird ausgelöst, wenn der übergebene Parameter kein iterierbares oder asynchron iterierbares Objekt ist (nicht die [Symbol.iterator]() oder [Symbol.asyncIterator]() Methode definiert). Ebenfalls ausgelöst, wenn während der Iteration das Ergebnis des nächsten Schritts kein Objekt ist oder ein Versprechen ist, das sich nicht zu einem Objekt auflöst.

Beispiele

Einen asynchronen Iterator in einen ReadableStream umwandeln

Dieses Live-Beispiel demonstriert, wie Sie einen asynchronen iterierbaren in einen ReadableStream umwandeln können und wie dieser Stream dann konsumiert werden könnte.

HTML

Das HTML besteht aus einem einzigen <pre>-Element, das zum Protokollieren verwendet wird.

<pre id="log"></pre>

JavaScript

Der Beispielcode erstellt eine log()-Funktion, um in das Protokoll-HTML-Element zu schreiben.

const logElement = document.getElementById("log");
function log(text) {
  logElement.innerText += `${text}\n`;
}

Es wird dann überprüft, ob die statische Methode unterstützt wird, und falls nicht, wird das Ergebnis protokolliert.

if (!ReadableStream.from) {
  log("ReadableStream.from() is not supported");
}

Der asynchrone Iterable ist eine anonyme Generatorfunktion, die die Werte 1, 2 und 3 liefert, wenn sie dreimal aufgerufen wird. Dies wird an ReadableStream.from() übergeben, um den ReadableStream zu erstellen.

// Define an asynchronous iterator
const asyncIterator = (async function* () {
  yield 1;
  yield 2;
  yield 3;
})();

// Create ReadableStream from iterator
const myReadableStream = ReadableStream.from(asyncIterator);

Using readable streams zeigt verschiedene Möglichkeiten, einen Stream zu konsumieren. Der folgende Code verwendet eine for ...await-Schleife, da diese Methode die einfachste ist. Jede Iteration der Schleife protokolliert den aktuellen Chunk des Streams.

consumeStream(myReadableStream);

// Iterate a ReadableStream asynchronously
async function consumeStream(readableStream) {
  for await (const chunk of readableStream) {
    // Do something with each chunk
    // Here we just log the values
    log(`chunk: ${chunk}`);
  }
}

Ergebnis

Das Ergebnis des Konsums des Streams wird unten angezeigt (wenn ReadableStream.from() unterstützt wird).

Ein Array in einen ReadableStream umwandeln

Dieses Beispiel demonstriert, wie Sie ein Array in einen ReadableStream umwandeln können.

<pre id="log"></pre>

const logElement = document.getElementById("log");
function log(text) {
  logElement.innerText += `${text}\n`;
}

if (!ReadableStream.from) {
  log("ReadableStream.from() is not supported");
}

JavaScript

Der Iterable ist einfach ein Array von Zeichenfolgen, das an ReadableStream.from() übergeben wird, um den ReadableStream zu erstellen.

// An Array of vegetable names
const vegetables = ["Carrot", "Broccoli", "Tomato", "Spinach"];

// Create ReadableStream from the Array
const myReadableStream = ReadableStream.from(vegetables);

consumeStream(myReadableStream);

// Iterate a ReadableStream asynchronously
async function consumeStream(readableStream) {
  for await (const chunk of readableStream) {
    // Do something with each chunk
    // Here we just log the values
    log(`chunk: ${chunk}`);
  }
}

Wir verwenden denselben Ansatz wie im vorherigen Beispiel, um das Protokoll zu führen und den Stream zu konsumieren, daher wird dies hier nicht gezeigt.

Ergebnis

Das Ergebnis wird unten angezeigt.

Spezifikationen

Browser-Kompatibilität

Siehe auch

• ReadableStream
• Using readable streams