RxJava Timeout ohne emiting Fehler?

Question

Gibt es eine Option, eine Variante timeout zu haben, die nicht Throwable ausstrahlt?

Ich möchte complete Ereignis gesendet haben.

Answer 1

Sie von einem Fehler mit einem anderen Observable, beispielsweise wieder aufnehmen kann:

Observable<String> data = ... 
data.timeout(1, TimeUnit.SECONDS) 
    .onErrorResumeNext(Observable.empty()) 
    .subscribe(...); 

Answer 2

Sie können immer onErrorResumeNext verwenden, die den Fehler bekommen und Sie können emittieren, was Artikel wollen- Sie

/** 
* Here we can see how onErrorResumeNext works and emit an item in case that an error occur in the pipeline and an exception is propagated 
*/ 
@Test 
public void observableOnErrorResumeNext() { 
    Subscription subscription = Observable.just(null) 
              .map(Object::toString) 
              .doOnError(failure -> System.out.println("Error:" + failure.getCause())) 
              .retryWhen(errors -> errors.doOnNext(o -> count++) 
                    .flatMap(t -> count > 3 ? Observable.error(t) : Observable.just(null)), 
                Schedulers.newThread()) 
              .onErrorResumeNext(t -> { 
               System.out.println("Error after all retries:" + t.getCause()); 
               return Observable.just("I save the world for extinction!"); 
              }) 
              .subscribe(s -> System.out.println(s)); 
    new TestSubscriber((Observer) subscription).awaitTerminalEvent(500, TimeUnit.MILLISECONDS); 
} 

Answer 3

Eine einfachere Lösung, die Observable.timeout nicht verwendet (es wird also kein Fehler mit dem Risiko des Einfangens unerwünschter Ausnahmen generiert), könnte einfach dauern, bis ein Timer abgeschlossen ist es:

Observable<String> data = ... 
data.takeUntil(Observable.timer(1, TimeUnit.SECOND)) 
    .subscribe(...);