@jil/pipeline
Pipe an input through a series of routines and tasks to produce an output, or simply, run logic in a series of stages
import { Context, WaterfallPipeline } from '@jil/pipeline';
const ast = new WaterfallPipeline(new Context(), filePath)
.pipe('Parsing AST', parseAst)
.pipe('Linting rules', runLintsOnAst)
.pipe('Transforming nodes', transformNodesOnAst)
.pipe('Writing contents', writeAstToFile)
.run();
Features
- Parallel and serial based processing pipelines.
- Supports 2 types of work units: tasks and routines.
- Pooling and aggregated implementations for computation heavy or complex logic.
- Contextually aware executions.
Installation
npm i @jil/pipeline