PipelineStream

pipeline-stream.ts

export class PipelineStream extends TransformStream {
  constructor(
    transformStreams: Array<TransformStream>,
    ...strategies: Array<QueuingStrategy>
  ) {
    super({}, ...strategies)

    const readable = [super.readable as any, ...transformStreams].reduce(
      (readable, transform) => readable.pipeThrough(transform)
    )

    Object.defineProperty(this, 'readable', {
      get() {
        return readable
      },
    })
  }
}