TransformStream 管道化数据处理与背压实践

概述TransformStream 提供可组合的数据管道能力。本文给出能力检测与端到端处理示例。能力检测与处理管道const supportsTS = typeof TransformStream === 'function';

function toUpperTransform() {

return new TransformStream({

transform(chunk, controller) {

const s = typeof chunk === 'string' ? chunk : new TextDecoder().decode(chunk);

controller.enqueue(new TextEncoder().encode(s.toUpperCase()));

}

});

}

async function processText(text) {

if (!supportsTS) return text.toUpperCase();

const rs = new Blob([text]).stream();

const out = rs.pipeThrough(toUpperTransform());

return await new Response(out).text();

}