RxJava - 使用 retryWhen 时超时

Question

我需要以 10 秒的间隔发送请求。这意味着下一个请求应该在收到上一个请求的响应后 10 秒内发送。最后一个请求应在 60 秒内开始。 例如：

0:00: 1st request: sent
0:05: 1st request: response
0:15: 2nd request: sent
0:45: 2nd request: response
0:55: 3rd request: sent
1:10: 3rd request: response
No more requests

这是我的代码：

mainRepository.getFlightSearchResults(uuid)
                .repeatWhen { it.delay(10, TimeUnit.SECONDS) }
                .timeout(60, TimeUnit.SECONDS)
                .observeOn(schedulerProvider.ui)

其中 getFlightSearchResults 返回 Observable。请求按上述方式发送，但请求在 60 秒后不会停止发送。如何在 60 秒后停止发送（未接收响应）请求？

Answer 1

使用 takeWhile 解决：

val startTimeMillis = System.currentTimeMillis()
mainRepository.getFlightSearchResults(uuid)
                .repeatWhen { it.delay(10, TimeUnit.SECONDS) }
                .takeWhile { System.currentTimeMillis() - startTimeMillis < 60_000 }
                .observeOn(schedulerProvider.ui)