TransformStream: TransformStream() コンストラクター

transformer 省略可

transformer を表すオブジェクト。指定されなかった場合、ストリームは同一変換ストリームとなり、書き込み可能な端点に書き込まれたすべてのチャンクをそのまま読み取り可能な端点に転送します。

変換オブジェクトは以下のメソッドを持つことができます。各メソッドの、 controller は TransformStreamDefaultController のインスタンスです。

start(controller)

TransformStream が構築される際に呼び出されます。通常は TransformStreamDefaultController.enqueue() を使用してチャンクをキューに入れます。

transform(chunk, controller)

書き込み可能な端点に書き込まれたチャンクが変換される準備ができたときに呼び出され、変換ストリームの作業をします。書き込み処理の成功や失敗を指示するプロミスを返すことがあります。もし transform() メソッドが与えられなかった場合、ID 変換が使用され、チャンクは変更されずにキューに入れられます。

flush(controller)

書き込み可能な端点に書き込まれたチャンクがすべて正常に変換され、書き込み可能な端点が閉じられた後に呼び出されます。

writableStrategy 省略可

オプションでストリームのキューイング戦略を定義するオブジェクト。これは 2 つの引数を取ります。

highWaterMark

非負の整数。これは、背圧が適用される前に内部キューに格納することができるチャンクの総数を定義します。

size(chunk)

引数 chunk を取るメソッド。これは各チャンクに使用するサイズをバイト単位で示します。

readableStrategy 省略可

オプションでストリームのキューイング戦略を定義するオブジェクト。 2 つの引数を取ります。

highWaterMark

非負の整数。これは、背圧が適用される前に内部キューに格納することができるチャンクの総数を定義します。

size(chunk)

引数 chunk を取るメソッド。これは各チャンクに使用するサイズをバイト単位で示します。

次の例は、チャンクごとにテキストを大文字に変換します。この例は Streams—The Definitive Guide から引用したもので、異なる種類のストリームの例が数多く含まれています。

function upperCaseStream() {
  return new TransformStream({
    transform(chunk, controller) {
      controller.enqueue(chunk.toUpperCase());
    },
  });
}

function appendToDOMStream(el) {
  return new WritableStream({
    write(chunk) {
      el.append(chunk);
    },
  });
}

fetch("./lorem-ipsum.txt").then((response) =>
  response.body
    .pipeThrough(new TextDecoderStream())
    .pipeThrough(upperCaseStream())
    .pipeTo(appendToDOMStream(document.body)),
);

引数 transformer を与えない場合は、書き込み可能な端点に書き込まれたチャンクを変更せずに読み取り可能な辺にすべて転送する同一変換ストリームになります。次の例では、パイプにバッファー機能を追加するために同一変換ストリームを使用しています。

const writableStrategy = new ByteLengthQueuingStrategy({
  highWaterMark: 1024 * 1024,
});
readableStream
  .pipeThrough(new TransformStream(undefined, writableStrategy))
  .pipeTo(writableStream);