A pure-Python library for composable stream processing pipelines with sync, async, and parallel execution plus a handy CLI.