Alternatively, you might be able to resubscribe on...
# rx
a
Alternatively, you might be able to resubscribe on an error via onErrorResume? But that would need to be explored.