java - 调试停止的 RxJava zip 运算符

Question

用 Java 编写我调用 zip() 方法，该方法接收一些返回 Observable<...> 的方法。

目前我无法进入下图，这可能是因为其中一种方法尚未返回值。 (尽管似乎调用了所有方法。)

有没有办法调试进程，看看为什么会卡？
谢谢。

Answer 1

假设你有:

result = Observable.zip(sourceA, sourceB, sourceC)

只需在每个源上添加一个 .doOnNext() 来记录它们发出的内容(或者代替 doOnNext，订阅每个源)。例如:

result = Observable.zip(sourceA.doOnNext(/*logging...*/),
                        sourceB.doOnNext(/*logging...*/),
                        sourceC.doOnNext(/*logging...*/))

可能发生的情况是这些来源之一的发射频率与其他来源不同。 zip 必须在您严格知道所有源都以相同的速度/频率发出事件时使用。您可能想尝试使用 combineLatest。两者的区别是:

• zip:返回的 Observable 仅在源的所有第 n 个项目都已发出时才发出第 n 个“组合”项目。查看diagram .
• combineLatest:返回的 Observable 会在其任何源发出一个项目时发出一个“组合”项目。查看diagram .