如何测试投掷的Kotlin Coroutine？

Question

（ kotlin 1.5.21，kotlinx-coroutines-test 1.5.0 ）

请考虑 androidx.lifecycle.viewmodel ：

fun mayThrow(){
    val handler = CoroutineExceptionHandler { _, t -> throw t }
    vmScope.launch(dispatchers.IO + handler) {
        val foo = bar() ?: throw IllegalStateException("oops")
        withContext(dispatchers.Main) {
            _someLiveData.value = foo
        }
    }
}

vmscope 对应于 ViewModelsCope ，在测试中，它被A testCoroutinesCope 代替。 dispatchers.io 是 dispatchers.io 的代理，在测试中，它是 testCoroutInedInedisPatcher 。在这种情况下，如果 bar（）返回null，则应用程序的行为是不确定的，因此，如果是这样，我希望它崩溃。现在我试图（JUNIT4）测试此代码：

@Test(expected = IllegalStateException::class)
fun `should crash if something goes wrong with bar`()  {
    tested.mayThrow()
}

测试失败是因为它应该测试的同样例外：

Exception in thread "Test worker @coroutine#1" java.lang.IllegalStateException: oops
// stack trace

Expected exception: java.lang.IllegalStateException
java.lang.AssertionError: Expected exception: java.lang.IllegalStateException
// stack trace

我感觉我在这里缺少一些很明显的东西...问题：是否是代码我的ViewModel是从Coroutine中抛出异常的正确方法，如果是，我该如何测试？

Answer 1

1. 为什么测试是绿色的：

代码启动{...} 与与
测试方法。要识别它尝试修改 maythrow 方法（请参阅代码
下面的摘要），因此它返回结果忽略了正在发生的事情
在内部启动{...} 上，将测试红色替换启动用
runblocking （

---

@Test
fun test() {
    assertEquals(1, mayThrow()) // GREEN
}

fun mayThrow(): Int {
    val handler = CoroutineExceptionHandler { _, t -> throw t }

    vmScope.launch(dispatchers.IO + handler) {
        val foo = bar() ?: throw IllegalStateException("oops")
        withContext(dispatchers.Main) {
            _someLiveData.value = foo
        }
    }

    return 1 // this line succesfully reached
}

2. 为什么看起来像“测试失败，因为同样的例外……”

测试不会失败，但是我们看到了控制台中的异常stacktrace，因为
默认异常处理程序可以使用并应用它，因为在这种情况下，自定义异常处理程序 coroutineExceptionHandler throws（）

3. 如何测试

功能 maythrow 具有太多职责，这就是为什么很难测试的原因。这是一个标准问题，并且存在标准处理（首先， 第二个）：长话短说是应用单个责任原则。
例如，将异常处理程序传递到功能

fun mayThrow(xHandler: CoroutineExceptionHandler){
    vmScope.launch(dispatchers.IO + xHandler) {
        val foo = bar() ?: throw IllegalStateException("oops")
        withContext(dispatchers.Main) {
            _someLiveData.value = foo
        }
    }
}

@Test(expected = IllegalStateException::class)
fun test() {
    val xRef = AtomicReference<Throwable>()
    mayThrow(CoroutineExceptionHandler { _, t -> xRef.set(t) })

    val expectedTimeOfAsyncLaunchMillis = 1234L
    Thread.sleep(expectedTimeOfAsyncLaunchMillis)

    throw xRef.get() // or assert it any other way
}

Answer 2

如果没有其他作用，我可以建议将代码（将异常）移动到另一种方法并测试此方法：

// ViewModel

fun mayThrow(){
    vmScope.launch(dispatchers.IO) {
        val foo = doWorkThatThrows()
        withContext(dispatchers.Main) {
            _someLiveData.value = foo
        }
    }
}

fun doWorkThatThrows(): Foo {
    val foo = bar() ?: throw IllegalStateException("oops")
    return foo
}

// Test

@Test(expected = IllegalStateException::class)
fun `should crash if something goes wrong with bar`()  {
    tested.doWorkThatThrows()
}

或使用 junit jupiter 允许使用 /a>方法。例子：

assertThrows<IllegalStateException> { tested.doWorkThatThrows() }