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.