OnErrorThrowable не найден в rxjava 2

Question

Я обновляю rxjava 1 до rxjava 2. Есть OnErrorThrowable в rxjava 1, но не найден в rxjava 2. Что я могу сделать в следующем коде для замены OnErrorThrowable?

static Observable<String> sampleObservable() { 
    return Observable.defer(new Callable<ObservableSource<String>>() { 
     @Override 
     public ObservableSource<String> call() throws Exception { 
      try { 
       // Do some long running operation 
       Thread.sleep(TimeUnit.SECONDS.toMillis(5)); 
      } catch (InterruptedException e) { 
       throw OnErrorThrowable.from(e); 
      } 
      Log.d(TAG, "The sleep is over, now produce something"); 
      return Observable.just("one", "two", "three", "four", "five"); 
     } 
    }); 
} 

Answer 1

В 2.x, вы не должны обернуть исключения, как все функциональные типы объявляют throws Exception:

static Observable<String> sampleObservable() { 
return Observable.defer(new Callable<ObservableSource<String>>() { 
    @Override 
    public ObservableSource<String> call() throws Exception { 
     Thread.sleep(TimeUnit.SECONDS.toMillis(5)); 
     Log.d(TAG, "The sleep is over, now produce something"); 
     return Observable.just("one", "two", "three", "four", "five"); 
    } 
}); 

}

Answer 2

Вы можете вернуть Observable.error(e); вместо того, чтобы бросать в свой улов блока.