超时的单元测试RxJava未订阅

Question

我有带超时的单元测试函数RxJava，但它没有订阅单元测试。视图上的函数模型

fun loadData() {
loadDataUseCase.loadData(true)
.subscribeOn(Schedulers.io())
.timeout(30L, TimeUnit.SECONDS, schedulers)
.observeOn(AndroidSchedulers.mainThread())
.doOnSubscribe {
onShowLoading.value = true
onShowError.value = false
onShowContent.value = false
}.subscribe(
{
onConnected.value = true
onShowContent.value = true
onShowError.value = false
onShowLoading.value = false
},
{
onShowError.value = true
onShowLoading.value = false
onShowContent.value = false
}
)
.addTo(compositeDisposable)
}

单元测试功能

@Test
fun `Load data is success`() {
// given
whenever(loadDataUseCase.loadData(true)).thenReturn(Observable.just(true))
// when
viewModel.loadData()
// then
viewModel.onShowError().test().assertValue(false).awaitNextValue().assertValue(false)
}

我试着调试这个函数，但它没有调用订阅

Answer 1

我有点困惑，onShowError((是什么？它会返回LiveData吗？

如果我运行相同的代码，测试甚至没有完成(我只使用io dispatchers和postValue(，对你来说，它可能在订阅发生之前就完成了：

由于您依赖Schedulers.io()，您的整个订阅可能在测试LiveData之前就已经完成。

另一种选择是您的LiveData已经有一个错误的值：.assertValue(false)。那么在调用订阅之前，下一个.doOnSubscribe设置已经触发.awaitNextValue()，并且整个测试完成。

你的测试应该是固定的，而不是依赖于时间。或者，如果这是不可避免的，那么你必须以某种方式同步你的测试，这里有一个例子：

@Timeout(1, unit = TimeUnit.SECONDS)
@Test
fun `Load data is success`() {
// given
whenever(loadDataUseCase.loadData(true)).thenReturn(Observable.just(true)

val testObserver = liveData.test()
testObserver.assertNoValue() // assert in correct state before actions

// when
loadData(liveData, mock)

//then
testObserver.awaitValueHistorySize(2)
.assertValueHistory(false, false)
}
fun <T> TestObserver<T>.awaitValueHistorySize(count: Int, delay: Long = 10): TestObserver<T> {
awaitValue()
while (valueHistory().size < count) {
// we need to recheck and don't block, the value we are trying to wait might already arrived between the while condition and the awaitNextValue in the next line, so we use some delay instead.
awaitNextValue(delay, TimeUnit.MILLISECONDS)
}
return this
}