We could add an interface to subscriptions that allows consuming messages as a Stream, like r2r.
Stream
r2r