12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849
import { Handler, HandlerGetter, Res, Status } from "./handler.ts";import { Pipe } from "./pipe.ts";import { HandlerBuilderGetter } from "./handler.ts";
export class Parallel implements Handler {  pipes: Pipe[];
  constructor() {    this.pipes = new Array<Pipe>();  }
  /** Handle the res, run pipes concrrently */  async handle(res: Res): Promise<Res> {    let reses = await Promise.all(      this.pipes.map((pipe) => {        return pipe.handle(res);      }),    );
    return {      status: Status.Ok,      data: reses.map((res) => res.data),    };  }}
export function buildParallel(  conf: any[],  builders?: HandlerBuilderGetter,  handlers?: HandlerGetter,): Parallel {  let parallel = new Parallel();  for (let pipeConf of conf) {    const pipe = new Pipe(pipeConf, builders, handlers);    parallel.pipes.push(pipe);  }
  return parallel;}
export function buildParallelWithJson(  jsonConf: string,  builders?: HandlerBuilderGetter,  handlers?: HandlerGetter,): Parallel {  const conf = JSON.parse(jsonConf);  return buildParallel(conf, builders, handlers);}