Ruby stream processing DSL