RxJava组合测试调试

Question

我使用的是RxJava组合测试操作符。

根据文档，订阅时，只有在两个可观察对象都发出这些值之后，才会发生第一个组合发射事件，从这一点开始，它将在每个可观察对象的每次发射时发射。

如何确定第一个可观察到的发射事件已经发生，它现在正在等待第二个...

Answer 1

您可以将doOnEach用于可观察对象和可流动对象，或将doOnEvent用于单打对象、可完成对象和可能存在的对象。这些操作所做的是每次从源发出一个项时，在将信号传递到下游之前执行一些代码。它对于将调试/日志代码“注入”到RX流中非常有用。

请参见：https://proandroiddev.com/briefly-about-rxjava-logging-20308b013e6d

编辑：

val a = BehaviorSubject.create<Int>().apply {
    onNext(1)
}.doOnEach { EventReporter.d(TAG, it.value?.toString() ?: "") }

val b = BehaviorSubject.create<Int>().apply {
    onNext(2)
}.doOnEach { EventReporter.d(TAG, it.value?.toString() ?: "") }

Observable.combineLatest(listOf(a, b), { args: Collection<Int> -> args}