ソースからの登録を解除しないでRxJavaのタイムアウト

Question

TimeoutExceptionがスローされたときに私は嫌いではないが、熱い観測可能なものを購読して、timeout演算子を適用しているが、私はソースが最終的に新しいアイテム）。それをどうすれば実現できますか？

私はonErrorReturnとタイムアウトを組み合わせようとしていますが、これもまたサブスクライバーでonCompleteコールを引き起こします。

Answer 1

は（my older answerから適応）、公開タイムアウトと再試行：魔法のように

Observable<Long> source = 
    Observable.just(100L, 200L, 500L, 1000L, 5000L, 5500L, 6000L) 
    .flatMap(v -> Observable.timer(v, TimeUnit.MILLISECONDS).map(a -> v)); 

source.publish(co -> 
    co.timeout(750, TimeUnit.MILLISECONDS, 
     Observable.just(-1L) 
     .concatWith(Observable.error(new RuntimeException())) 
    ) 
    .retry() 
).blockingForEach(System.out::println);