ReadableStream: метод pipeThrough()

Метод pipeThrough() интерфейса ReadableStream предоставляет цепной способ передачи текущего потока через поток преобразования или любую другую пару потоков «ввод/вывод».

Передача потока обычно блокирует его на время передачи, предотвращая блокировку другими читателями.

transformStream

Объект TransformStream (или объект со структурой {writable, readable}) состоящий из потока чтения и потока записи, работающих совместно для преобразования данных из одной формы в другую. Данные, записанные в поток writable могут быть прочитаны в преобразованном виде потоком readable. Например, в TextDecoder байты записываются, а строки считываются, в то время как декодер видео записывает закодированные байты и считывает из них несжатые видеокадры.

options Необязательно

Параметры, которые должны быть использованы при передаче в поток writable. Доступные параметры:

preventClose

Если это значение установлено в true, закрытие исходного потока ReadableStream больше не будет приводить к закрытию целевого потока WritableStream.

preventAbort

Если это значение установлено в true, ошибки в исходном потоке ReadableStream больше не будут прерывать целевой поток WritableStream.

preventCancel

Если это значение установлено в true, ошибки в целевом потоке WritableStream больше не будут отменять исходный поток ReadableStream.

signal

Если установлено в объект AbortSignal, операции передачи могут быть прерваны с помощью соответствующего объекта AbortController.

readable сторона потока transformStream.

TypeError

Выбрасывается, если свойство writable и/или readable объекта transformStream не определены.

В следующем примере (см. Распаковать фрагменты PNG для полного кода, выполняющегося в режиме реального времени, и png-transform-stream для исходного кода) изображение загружается, а его тело извлекается в виде ReadableStream.

Далее, мы выводим содержимое потока чтения, используем pipeThrough() для передачи его в новую функцию, которая создаёт оттенок серого изображения, и затем выводим содержимое нового потока.

// 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() конструктор
• Цепочки передачи