TransformStream

Aprenda sobre TransformStream.

Ver como Markdown

TransformStream representa uma implementação concreta do conceito de pipe chain transform.

TransformStream pode ser passado para o método ReadableStream.pipeThrough() para transformar os dados da stream de um formato para outro. Por exemplo, pode ser usado para decodificar ou codificar frames de vídeos, descompactar dados ou converter a stream de XML para JSON.

Um algoritmo de transformação pode ser informado como um argumento opcional para o objeto construtor. Se não informado, os dados não serão modificados.

TransformStream é um objeto transferível.

Construtor

TransformStream() Cria e retorna um objeto transform stream, especificando opcionalmente um transformation object e ordenando estratégias para as streams.

Propriedades

TransformStream.readable A ponta que possibilita ser realizada a leitura de um TransformStream.

TransformStream.writable A ponta que possibilita ser realizada a escrita de um TransformStream.

Exemplos

Anything-to-uint8array stream

No exemplo a seguir, um transform stream passa por todos os blocos recebidos como valores Uint8Array.

const transformContent = {
start() {}, // obrigatório
async transform(chunk, controller) {
chunk = await chunk;
switch (typeof chunk) {
case 'object':
// informa que a stream finalizou
if (chunk === null) {
controller.terminate();
} else if (ArrayBuffer.isView(chunk)) {
controller.enqueue(new Uint8Array(chunk.buffer, chunk.byteOffset, chunk.byteLength));
} else if (
Array.isArray(chunk) &&
chunk.every((value) => typeof value === 'number')
) {
controller.enqueue(new Uint8Array(chunk));
} else if (
typeof chunk.valueOf === 'function' &&
chunk.valueOf() !== chunk
) {
this.transform(chunk.valueOf(), controller); // hack
} else if ('toJSON' in chunk) {
this.transform(JSON.stringify(chunk), controller);
}
break;
case 'symbol':
controller.error("Cannot send a symbol as a chunk part")
break
case 'undefined':
controller.error("Cannot send undefined as a chunk part")
break
default:
controller.enqueue(this.textencoder.encode(String(chunk)))
break
}
},
flush() {}
}
class AnyToU8Stream extends TransformStream {
constructor() {
super({...transformContent, textencoder: new TextEncoder()})
}
}

Para mais informações sobre TransformStream visite MDN Web Docs.