We could add an interface to subscriptions that allows consuming messages as a [`Stream`](https://docs.rs/futures/latest/futures/stream/trait.Stream.html), like `r2r`.
