`onErrorResumeNext { Single.fromCallable { message...
# rx
u
onErrorResumeNext { Single.fromCallable { messageRepository.updateMessageState(messageId, MessageState.ERROR) }}
?