如何解决涉及 MutableSharedFlow 的测试 - java.lang.IllegalStateException:此作业尚未完成
对于可能是非常业余的问题表示歉意。
我正在处理流程问题,并在 MutableSharedFlow
所关注的测试中遇到问题。
以下是我可以构建的重现问题的最简单示例:
@ExperimentalCoroutinesApi
@ExperimentalTime
class MyExampleTest {
val testdispatcher: TestCoroutinedispatcher = TestCoroutinedispatcher()
@Test
fun test() = testdispatcher.runBlockingTest {
val sharedFlow = MutableSharedFlow<String>()
sharedFlow.take(2).collect {
println(it)
}
sharedFlow.tryEmit("Hello")
sharedFlow.tryEmit("World")
}
}
这会导致以下错误:
java.lang.IllegalStateException: This job has not completed yet
at kotlinx.coroutines.JobSupport.getCompletionExceptionorNull(JobSupport.kt:1187)
at kotlinx.coroutines.test.TestBuildersKt.runBlockingTest(TestBuilders.kt:53)
at kotlinx.coroutines.test.TestBuildersKt.runBlockingTest(TestBuilders.kt:80)
at com.example.MyExampleTest.test(MyExampleTest.kt:22)
根据我有限的理解,我认为这与 SharedFlow
永远不会完成的事实有关。但我认为拥有 take(2)
可以缓解这种情况。任何建议将不胜感激!
解决方法
根据我有限的理解,我认为这与 SharedFlow 从未完成这一事实有关。
你说得对,这或多或少是问题所在。 Flow基于Coroutines,协程未完成。
在我看来,对 Flows 进行单元测试的最佳方法是 Turbine:
https://github.com/cashapp/turbine
// Cold Flow
flowOf("one","two").test {
assertEquals("one",expectItem())
assertEquals("two",expectItem())
expectComplete()
}
// Hot Flow
MutableStateFlow("test").test {
assertThat(expectItem()).isEqualTo("test")
cancelAndConsumeRemainingEvents()
}
关于这个确切的“问题”还有一个未解决的问题:
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。