android - 协程单元测试单独通过,但一起运行时不通过
问题描述
我有两个协程测试在单独运行时都通过了,但是如果我一起运行它们,第二个总是失败(即使我切换它们!)。我得到的错误是:
需要但未调用:observer.onChanged([SomeObject(someValue=test2)]); 实际上,与此模拟的交互为零。
关于协程(或一般测试)和做错事,我可能不了解一些基本的东西。
如果我调试测试,我发现失败的测试没有等待内部runBlocking
完成。实际上,我runBlocking
首先拥有内部的原因是为了解决这个确切的问题,它似乎适用于个人测试。
关于为什么会发生这种情况的任何想法?
测试班
@ExperimentalCoroutinesApi
@RunWith(MockitoJUnitRunner::class)
class ViewModelTest {
@get:Rule
val instantTaskExecutorRule = InstantTaskExecutorRule()
private lateinit var mainThreadSurrogate: ExecutorCoroutineDispatcher
@Mock
lateinit var repository: DataSource
@Mock
lateinit var observer: Observer<List<SomeObject>>
private lateinit var viewModel: SomeViewModel
@Before
fun setUp() {
mainThreadSurrogate = newSingleThreadContext("UI thread")
Dispatchers.setMain(mainThreadSurrogate)
viewModel = SomeViewModel(repository)
}
@After
fun tearDown() {
Dispatchers.resetMain()
mainThreadSurrogate.close()
}
@Test
fun `loadObjects1 should get objects1`() = runBlocking {
viewModel.someObjects1.observeForever(observer)
val expectedResult = listOf(SomeObject("test1"))
`when`(repository.getSomeObjects1Async())
.thenReturn(expectedResult)
runBlocking {
viewModel.loadSomeobjects1()
}
verify(observer).onChanged(listOf(SomeObject("test1")))
}
@Test
fun `loadObjects2 should get objects2`() = runBlocking {
viewModel.someObjects2.observeForever(observer)
val expectedResult = listOf(SomeObject("test2"))
`when`(repository.getSomeObjects2Async())
.thenReturn(expectedResult)
runBlocking {
viewModel.loadSomeObjects2()
}
verify(observer).onChanged(listOf(SomeObject("test2")))
}
}
视图模型
class SomeViewModel constructor(private val repository: DataSource) :
ViewModel(), CoroutineScope {
override val coroutineContext: CoroutineContext
get() = Dispatchers.Main
private var objects1Job: Job? = null
private var objects2Job: Job? = null
val someObjects1 = MutableLiveData<List<SomeObject>>()
val someObjects2 = MutableLiveData<List<SomeObject>>()
fun loadSomeObjects1() {
objects1Job = launch {
val objects1Result = repository.getSomeObjects1Async()
objects1.value = objects1Result
}
}
fun loadSomeObjects2() {
objects2Job = launch {
val objects2Result = repository.getSomeObjects2Async()
objects2.value = objects2Result
}
}
override fun onCleared() {
super.onCleared()
objects1Job?.cancel()
objects2Job?.cancel()
}
}
存储库
class Repository(private val remoteDataSource: DataSource) : DataSource {
override suspend fun getSomeObjects1Async(): List<SomeObject> {
return remoteDataSource.getSomeObjects1Async()
}
override suspend fun getSomeObjects2Async(): List<SomeObject> {
return remoteDataSource.getSomeObjects2Async()
}
}
解决方案
当您使用 时launch
,您正在创建一个异步执行的协程。使用runBlocking
不会影响这一点。
你的测试失败了,因为你的 launch 里面的东西会发生,但还没有发生。
在执行任何断言之前确保您的启动已执行的最简单方法是调用.join()
它们。
fun someLaunch() : Job = launch {
foo()
}
@Test
fun `test some launch`() = runBlocking {
someLaunch().join()
verify { foo() }
}
而不是保存你的个人Jobs
,ViewModel
你onCleared()
可以CoroutineScope
像这样实现:
class MyViewModel : ViewModel(), CoroutineScope {
private val job = SupervisorJob()
override val coroutineContext : CoroutineContext
get() = job + Dispatchers.Main
override fun onCleared() {
super.onCleared()
job.cancel()
}
}
在 a 内发生的所有启动都CoroutineScope
成为 that 的子级CoroutineScope
,因此如果您取消它job
(这实际上是取消了CoroutineScope
),那么您将取消在该范围内执行的所有协程。
所以,一旦你清理了你的CoroutineScope
实现,你可以让你的ViewModel
函数只返回Job
s:
fun loadSomeObjects1() = launch {
val objects1Result = repository.getSomeObjects1Async()
objects1.value = objects1Result
}
现在您可以使用以下命令轻松测试它们.join()
:
@Test
fun `loadObjects1 should get objects1`() = runBlocking {
viewModel.someObjects1.observeForever(observer)
val expectedResult = listOf(SomeObject("test1"))
`when`(repository.getSomeObjects1Async())
.thenReturn(expectedResult)
viewModel.loadSomeobjects1().join()
verify(observer).onChanged(listOf(SomeObject("test1")))
}
我还注意到你正在使用Dispatchers.Main
你的ViewModel
. 这意味着默认情况下您将在主线程上执行所有协程。你应该考虑一下这是否真的是你想做的事情。毕竟,Android 中很少有非 UI 的事情需要在主线程上完成,而且你的 ViewModel 不应该直接操作 UI。
推荐阅读
- javascript - 按下按钮的次数,应乘以变量(recipeTotal)值
- spring - Flutter,通过 Dio/http 将嵌套的 FormData 发送到服务器
- java - Java输入读取字符串进行验证
- cookies - 如何确保 CloudFront 从我的 Elastic Beanstalk REST API 应用程序返回 cookie
- snowflake-cloud-data-platform - 如何检查一个json是否包含雪花中的另一个json
- javascript - Angular 7在创建时间超过6个月时隐藏一个div
- python - 用用户输入列表替换列表
- android - Android 11 - 访问 Android/data 目录
- php - PHP AJAX登录表单运行AJAX失败代码
- html - 蓝色选择区域太大