Rxjava最短执行时间？

Question

我有一个 Observable A 和一个 Observable B。现在我必须等待这些 Observable 完成或至少 30 秒。我如何在 RxJava 上实现这个？

感谢任何建议！

Answer 1

除了等待完成之外，你还没有说你想对 a 和 b 的排放做什么，但你可以这样做：

Observable.merge(
    Observable.timer(30, TimeUnit.SECONDS)
        .ignoreElements().cast(Object.class),
    a.ignoreElements().cast(Object.class),
    b.ignoreElements().cast(Object.class));

Rxjava最短执行时间？

Rxjava minimum time execution?

rx-java

rx-android