← Cloudflare Workers / workers / runtime-apis / streams

TransformStream

TransformStream состоит из пары потоков: writable-потока, который называют writable-стороной, и readable-потока, который называют readable-стороной. Запись в writable-сторону делает новые данные доступными для чтения из readable-стороны.

На данный момент Workers реализует только identity transform stream: тип transform stream, который передаёт все чанки, записанные в его writable-сторону, в readable-сторону без каких-либо изменений.

let { readable, writable } = new TransformStream();

• TransformStream() TransformStream

  • Возвращает новый поток преобразования типа identity.

• readable ReadableStream
  • Экземпляр ReadableStream.
• writable WritableStream
  • Экземпляр WritableStream.

Текущая реализация TransformStream в платформе Workers на данный момент не соответствует Стандарт Streams ↗ и скоро мы внесём изменения в реализацию, чтобы привести её в соответствие со спецификацией. Готовясь к этому, мы ввели IdentityTransformStream класс, реализующий поведение, идентичное текущему TransformStream класс. Этот тип потока передаёт все фрагменты байтовых данных (в виде TypedArrays), записанные в записываемую сторону, в читаемую сторону без каких-либо изменений.

IdentityTransformStream читаемая сторона поддерживает чтение с использованием собственного буфера (BYOB) ↗.

let { readable, writable } = new IdentityTransformStream();

• IdentityTransformStream() IdentityTransformStream

  • Возвращает новый поток преобразования типа identity.

• readable ReadableStream
  • Экземпляр ReadableStream.
• writable WritableStream
  • Экземпляр WritableStream.

FixedLengthStream представляет собой специализацию IdentityTransformStream который ограничивает общее количество байтов, пропускаемых потоком. Это полезно прежде всего потому, что при использовании FixedLengthStream чтобы получить либо Response или Request, фиксированная длина потока будет использована в качестве Content-Length заголовка вместо использования chunked encoding при работе с любым другим типом потока. Если через поток будет записано слишком много или слишком мало байт, возникнет ошибка.

let { readable, writable } = new FixedLengthStream(1000);

• FixedLengthStream(length) FixedLengthStream

  • Возвращает новый поток преобразования типа identity.
  • length возможно, number или bigint с максимальным значением 2^53 - 1.

• readable ReadableStream
  • Экземпляр ReadableStream.
• writable WritableStream
  • Экземпляр WritableStream.

• Streams
• Transform Streams в спецификации WHATWG Streams API ↗