Skip to content

Latest commit

 

History

History
39 lines (27 loc) · 737 Bytes

README.md

File metadata and controls

39 lines (27 loc) · 737 Bytes
Raw

pipeline

move your data using node.js std lib

empowered by composed async generator functions and iterators

Install

npm install https://github.com/jtara1/pipeline

Usage

import { pipeline } from 'pipeline';
import { map, arraySink } from 'pipeline/steps/common.steps.js';

const result = await pipeline(
  [1, 2, 3, 4],
  map(value => value ** 2),
  arraySink(),
);

console.log(result);

TODO

  • common steps
  • exit code 1
  • re-read all steps
  • refactor step functions to all be a function to explicitly call
  • refactor modules to group sinks
  • document pipeline, steps, and sinks
  • docstrings for common.step.mjs functions
  • testing for the functions ^