ReadableStream: pipeThrough()-Methode

transformStream

Ein TransformStream (oder ein Objekt mit der Struktur {writable, readable}), das aus einem lesbaren und einem beschreibbaren Stream besteht, die zusammenarbeiten, um einige Daten von einer Form in eine andere zu transformieren. Daten, die in den writable-Stream geschrieben werden, können in einem transformierten Zustand vom readable-Stream gelesen werden. Beispielsweise hat ein TextDecoder Bytes, die in ihn geschrieben werden, und Zeichenketten, die aus ihm gelesen werden, während ein Videodecoder kodierte Bytes in ihn geschrieben und unkomprimierte Videoframes aus ihm gelesen werden.

options Optional

Die Optionen, die beim Piping zum writable-Stream verwendet werden sollen. Verfügbare Optionen sind:

preventClose

Wenn diese Option auf true gesetzt ist, führt das Schließen des Quell-ReadableStream nicht mehr dazu, dass der Ziel-WritableStream geschlossen wird.

preventAbort

Wenn diese Option auf true gesetzt ist, führen Fehler im Quell-ReadableStream nicht mehr dazu, dass der Ziel-WritableStream abgebrochen wird.

preventCancel

Wenn diese Option auf true gesetzt ist, führen Fehler im Ziel-WritableStream nicht mehr dazu, dass der Quell-ReadableStream abgebrochen wird.

signal

Wenn ein AbortSignal-Objekt gesetzt ist, können laufende Pipe-Operationen über den entsprechenden AbortController abgebrochen werden.

Die readable-Seite des transformStream.

TypeError

Ausgelöst, wenn die writable- und/oder readable-Eigenschaft von transformStream nicht definiert ist.

Im folgenden Beispiel (siehe Unpack chunks of a PNG für den vollständigen Code, der live ausgeführt wird, und png-transform-stream für den Quellcode) wird ein Bild abgerufen und dessen Body als ReadableStream abgerufen.

Anschließend protokollieren wir den Inhalt des lesbaren Streams, verwenden pipeThrough(), um ihn an eine neue Funktion zu senden, die eine grau gefärbte Version des Streams erstellt, und protokollieren dann auch den neuen Streaminhalt.

// Fetch the original image
fetch("png-logo.png")
  // Retrieve its body as ReadableStream
  .then((response) => response.body)
  .then((rs) => logReadableStream("Fetch Response Stream", rs))
  // Create a gray-scaled PNG stream out of the original
  .then((body) => body.pipeThrough(new PNGTransformStream()))
  .then((rs) => logReadableStream("PNG Chunk Stream", rs));

• ReadableStream()-Konstruktor
• Pipe-Ketten