TransformStream

TransformStream 对象由一对流组成：一个可读流（称为可读端）和一个可写流（称为可写端）。写入可写端的数据将作为新数据可从可读端读取。 它基于 Web APIs 标准 TransformStream 接口设计，您可以在 Edge Cloud Apps 函数中使用 TransformStream 对象来处理流式数据，例如转换数据格式、压缩数据、加密数据等。

构造函数

new TransformStream(transformer?: Transformer, writableStrategy?: WritableStrategy);

参数：

WritableStrategy

属性

readable

• 类型: ReadableStream (只读)
• 描述: 可读端，详情参见 ReadableStream。

writable

• 类型: WritableStream (只读)
• 描述: 可写端，详情参见 WritableStream。

示例代码

async function handleEvent(event) {
  // 生成可读端与可写端
  const { readable, writable } = new TransformStream();
  // 获取远程资源 
  const response = await fetch('https://www.tencentcloud.com/');
  // 流式响应客户端 
  response.body.pipeTo(writable);

  return new Response(readable, response);
}

addEventListener('fetch', (event) => {
  event.respondWith(handleEvent(event));
});

IdentityTransformStream

IdentityTransformStream 类实现了与当前 TransformStream 类相同的行为。 这种类型的流将写入其可写端的所有字节数据块（以 TypedArrays 的形式）转发到其可读端，不做任何更改。

IdentityTransformStream 可读端支持自带缓冲区 (BYOB) 读取。

构造函数

new IdentityTransformStream();

返回值： 返回一个新的 identity transform stream。

属性

readable

• 类型: ReadableStream
• 描述: 一个 ReadableStream 实例。

writable

• 类型: WritableStream
• 描述: 一个 WritableStream 实例。

FixedLengthStream

FixedLengthStream 是 IdentityTransformStream 的一种特化，它限制了流将传递的总字节数。 它主要用于在使用 FixedLengthStream 生成 Response 或 Request 时，流的固定长度将用作 Content-Length 标头值，而不是在使用任何其他类型的流时使用分块编码。 如果通过流写入的字节过多或过少，则会发生错误。

构造函数

new FixedLengthStream(length: number | bigint);

参数：

• length: 一个数字或 bigint，表示流将传递的总字节数。 最大值为 2^53 - 1。

返回值： 返回一个新的 identity transform stream。

属性

readable

• 类型: ReadableStream
• 描述: 一个 ReadableStream 实例。

writable

• 类型: WritableStream
• 描述: 一个 WritableStream 实例。

相关参考

• Streams
• WHATWG Streams API 规范中的转换流
• MDN TransformStream 文档