RxJava Completable和第二次测试

Question

我有以下RxJava2 Kotlin代码：

val tester = Completable.complete()
            .andThen(SingleSource<Int> { Single.just(42) })
            .test()        
tester.assertComplete()
tester.assertValue(42)

这模拟了一个可完全观察的对象（想象对API的一个简单更新操作），然后是一个可观察的对象（图像是API上的一个get操作）。我希望以一种方式连接这两个可观察对象，当Completable完成时，运行单个对象，最后在我的观察者（Int 42）上获得onSuccess事件。

但是，此测试代码不起作用。断言失败，出现以下错误：

java.lang.AssertionError: Not completed
(latch = 1, values = 0, errors = 0, completions = 0))

我无法理解我做错了什么，我希望Compltable在订阅时发出on完整，然后是单一订阅，我的观察者（tester）得到一个值为42的on成功事件，但似乎订阅保持“暂停”不发出任何东西。

这个想法与本文中的想法类似：https://android.jlelse.eu/making-your-rxjava-intentions-clearer-with-single-and-completable-f064d98d53a8

apiClient.updateMyData(myUpdatedData) // a Completable
    .andThen(performOtherOperation()) // a Single<OtherResult>
    .subscribe(otherResult -> {
        // handle otherResult
    }, throwable -> {
        // handle error
    });

Answer 1

问题在于静态编程语言对花括号的模糊使用：

.andThen(SingleSource<Int> { Single.just(42) })

您创建了一个SingleSource，它会注意到它的SingleWatch，但这被静态编程语言语法隐藏。您需要的是简单易用：

.andThen(Single.just(42))

或延期使用

.andThen(Single.defer { Single.just(42) })