OnErrorThrowable nicht gefunden in rxjava 2

Question

Ich rxjava 1 auf rxjava 2 upgraden. Es gibt OnErrorThrowable in rxjava 1, aber nicht in rxjava 2. Was kann ich im folgenden Code, um die OnErrorThrowable zu ersetzen?

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

In 2.x Sie müssen keine Ausnahmen wickeln, da alle Funktionstypen throws Exception erklären:

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

Sie können Observable.error(e); zurückgeben, anstatt Ihren Catch-Block einzuwerfen.