Flink-style stream reducing: `step.subscribe`
Add a tool which allows for continual linear subscriptions to an event stream, eg: `step.subscribe("event/name", { if: "xyz == 123", timeout: "10m" }, (acc, async, ctx) => {})`. This lets us listen for all events of a type within a function.