When blocking on the queue of messages from a subscribe command, if the connection break, there will never be more events.
- make the caller aware of that somehow?
- alternative: called must timeout and test connection is alive
- better: restart the subscribe after reconnecting, and keep going
- would be best if an async generator was used instead of queues
When blocking on the queue of messages from a subscribe command, if the connection break, there will never be more events.