@boost/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 '@boost/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
yarn add @boost/pipeline
Documentation
Index
Classes
Interfaces
Type Aliases
Variables
Type Aliases
Action
Type parameters
- Ctx: Context
- Input = unknown
- Output = Input