ursus
onErrorResumeNext { Single.fromCallable { messageRepository.updateMessageState(messageId, MessageState.ERROR) }}