エラーを出すことなくRxJavaタイムアウト？

Question

異種のtimeoutにはThrowableを発行しないオプションがありますか？

私はcompleteイベントを送信したいと思います。

Answer 1

は、あなたが他のObservableとエラーから再開することができwant-どんなアイテム発することができます。

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

Answer 2

あなたは常にエラーになりますどの onErrorResumeNext を使用することができ、あなたが、たとえば、

/** 
* 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

Observable.timeoutを使用しないより簡単な解決法（したがって、不要な例外をキャッチするリスクを伴わないエラーを生成しない）は、タイマーが完了するまでESは：

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