Re-organized stream pipelines, added a CLI utility

Re-organized stream pipelines

Added a command-line utility.
Usage: node ./bin/cli.js

TODO:
- write a README
- usage examples
- commit tests