Stream API - 转换流

在Stream API中，转换流用于实现管道链概念。 管链是多个流相互连接的过程。 原始源称为管链的起点，而最终汇点称为管链的终点。

TransformStream 接口

Stream API 支持两种类型的转换流接口 −

• TransformStream 接口

• TransformStreamDefaultController

TransformStream 接口

TransformStream接口用于实现管链变换流方法。

构造函数

为了创建转换流对象，TransformStream 接口提供了 TransformStream() 构造函数。 该对象代表一对流，即可写端的 WritableStream 和可读端的 ReadableStream。

语法

const newTrans = new TransformStream()
Or
const newTrans = new TransformStream(mtransform)
Or
const newTrans = new TransformStream(mtransform, writableStrategy)
Or
const newTrans = new TransformStream(mtransform, writableStrategy, readableStrategy)

以下是 TransformStream() 构造函数的可选参数 −

• mtransform − 该对象代表 transformer。 start(controller)、transform(chunk,controller)和flush(controller)是transformer对象包含的方法。 其中控制器是 TransformStreamDefaultController 的实例。

• writableStrategy − 该对象用于定义写入流的排队策略。 它需要两个参数:highWaterMark 和 size(chunk)。

• readableStrategy − 该对象用于定义读取流的排队策略。 它需要两个参数:highWaterMark 和 size(chunk)。

实例属性

TransformStream 接口提供的属性是只读属性。 所以TransformStream提供的属性是 −

TransformStreamDefaultController 接口

TransformStreamDefaultController 接口提供了各种方法来操作 ReadableStream 和 WritableStream。 当我们创建 TransformStream 时，就会自动创建 TransformStreamDefaultController。 因此它不需要任何单独的构造函数。

实例属性

TransformStreamDefaultController 接口提供的属性是只读属性。 所以 TransformStreamDefaultController 提供的属性是 −

方法

以下是TransformStreamDefaultController接口的常用方法 −

示例 - 创建转换流

在下面的程序中，我们创建一个自定义转换流。 因此，为了创建转换流，我们使用 TransformStream() 构造函数以及 transform()、flush()、start() 和 cancel() 函数。 Transform() 函数实现接收到的块，然后将它们转换为大写，然后使用 enqueue() 方法将数据排入队列。 flash() 方法用于处理流终止，start() 方法用于处理初始化，cancel() 方法用于处理取消。 现在我们使用 getWriter() 方法从转换流中获取 writer 来读取流的数据。 然后我们使用 getReader() 函数获取转换流的读取器。 它借助 myread() 函数从流中读取并处理转换后的数据。

<!DOCTYPE html>
<html>
<body>
<script>
   // 使用 TransformStream() 构造函数创建转换流
   const newTransform = new TransformStream({
      transform(chunk, controller) {
         // 以大写形式处理接收到的块
         const tData = chunk.toString().toUpperCase();

         // 将转换后的数据入队并传递给下游
         controller.enqueue(tData);
      },
      // 如果需要，处理最终数据
      flush(controller) {
         console.log('Stream is flushing');
      },
      // 如果需要，执行初始化
      start(controller) {
         console.log('Stream is started');
      },
      // 如果流被取消，则对其进行处理
      cancel(reason) {
         console.log('Stream got canceled:', reason);
      }
   });
   // 为转换流创建编写器
   const twriter = newTransform.writable.getWriter();

   // 将数据写入转换流
   twriter.write('pink');
   twriter.write('green');
   twriter.write('blue');

   // 关闭流
   twriter.close();

   // 为转换流创建读取器
   const treader = newTransform.readable.getReader();

   // 从转换流中读取并处理数据
   function myread(){
      treader.read().then(({ done, value }) => {
         if (done) {
            console.log('Stream is ended');
            return;
         }
         // 处理接收到的转换后的数据
         console.log(value);

         // 继续从流中读取数据
         myread();
      });
   }
   // 调用 myread() 开始从转换流中读取
   myread();
</script>
</body>
</html>

结论

这就是转换流的工作原理。 它通常在我们将多个流连接在一起时使用。 在下一篇文章中，我们将了解 Stream API 中的对象模式。