установить исключение с помощью javarx

Question

У меня есть следующий код, когда генерируется исключение, я им управляю, но моя идея состоит в том, что, когда что-то не получается, я возвращаю плохой запрос и оставляю код один раз.

var token: TokenResponse? = null

        userService.login(request)
                .map { result -> result.token }.subscribe(
                        { result -> token = result },
                        { error ->
                            val exception = UserException(ErrorCode.INVALID_USER_GRIN, error.message!!)
                            monitorHelper.noticeError(exception)
                        },
                        { logger.info("[GET_TOKEN{}]: end get token request", token) }
                )

        return token