unix-pipeline-like stream processing in python
The goal: pipelien equivalence
Given this pipeline in unix shell:
foo | bar | baz
we should have this in python:
foo >> bar >> baz
Any segment should be easily swappable between the python and shell version. Command foo should be callable from python. Conversely python function that implements a segment should be callable as a command.