java - RxJava Observable 最短执行时间

Question

我有一个 Observable(从网络获取数据)。问题是 Observable 可能快也可能慢，这取决于网络条件。

我在 observable 执行时显示进度小部件，并在 observable 完成时隐藏它。当网络速度快时 - 进度闪烁(出现和消失)。我想将 observable 的最短执行时间设置为 1 秒。我该怎么做？

“延迟”运算符不是一个选项，因为它即使对于慢速网络也会延迟。

Answer 1

您可以为此使用 Observable.zip()。给定

Observable<Response> network = ...

可以做到

Observable<Integer> readyNotification = Observable.just(42).delay(1, TimeUnit.SECONDS);
Observable delayedNetwork = network.zipWith(readyNotification, 
                                                (response, notUsed) -> response);