import { Pipeline } from "https://deno.land/x/aip@v1.2.2/mod.ts";
Represents sum of multiple .addStage(…)'s and/or .addPipeline(…)'s
acting on messages .put(…) into it. .fork(…) can be used to have multiple
instances of the same set of Stage's. No stage execution occur unless async
iteration happens on the pipeline (and values are .put(…) into it).