Как правильно обрабатывать ошибки в rxJava 2?

Проект состоит из 3 частей data ,presentation,domain В data есть репозиторий который получает данные трансформирует их в обьект для domain и в принципе все дальше не важно.Так вот как обработать ошибку если данные не пришли,Как вообще правильно обрабатывать ошибки в Rx ?код применрно такой

 @Override
    public Observable<AuthorizationModel> getPostById(String postId) {
          return restClient.getAutrorizationApi(postId)
                 .map(this.authorizationEntityDataMapper::transform)
                 .subscribeOn(Schedulers.io())
                 .observeOn(AndroidSchedulers.mainThread());
    }