Used rxJava2 and retrofit2 .

  public Observable<xxx> go(){ return Rest.getNews(date) .observeOn(DatabaseScheduler.get()) .flatMap(//Тут абсолютно неважный код) .toObservable() .flatMap(//Тут абсолютно неважный код); }}

So, the getNews method accesses the server, and if there is no Internet, or the server is not available, then an error falls out and the application crashes. The question is how to catch the error and handle it in subscribe ?

    1 answer 1

      Rest.getNews(date) .observeOn(DatabaseScheduler.get()) .flatMap(//Тут абсолютно неважный код) .toObservable() .flatMap(//Тут абсолютно неважный код); .subscribe( (result) -> { /* Все хорошо */ }, (throwable) -> { /* Обрабатываем ошибку */ });
    • thank you so much, now it all worked. - Nikita