RxJava超時沒有退訂源

Question

我訂閱熱可觀察，然後應用timeout運營商，但我不想取消訂閱TimeoutException時，只產生特殊項目（我知道源將最終發出新的項目）。我怎樣才能做到這一點？

我試圖結合超時與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);