Ractor::Pipeline provides a shell-pipeline-like DSL (stream/pipe/filter_pipe/flat_pipe/tee/lanes) where each stage is a persistent Ractor, making the execution topology visible in the code. Multi-lane stages are fed by demand (pull) and sources can be batched transparently.