- c - 在位数组中找到第一个零
- linux - Unix 显示有关匹配两种模式之一的文件的信息
- 正则表达式替换多个文件
- linux - 隐藏来自 xtrace 的命令
背景:
我有一个简单的应用程序,它使用 rests API 调用来获取电影列表。项目结构如下,
Activity -> ViewModel -> Repository -> ApiService (Retrofit Interface)
Activity 订阅一个LiveData并监听事件变化
ViewModel 托管 Activity 观察到的 MediatorLiveData。最初,ViewModel 在 MediatorLiveData 中设置一个 Resource.loading(..)
值。
ViewModel 然后调用存储库从 ApiService 获取电影列表
ApiService 返回 Resource.success(..)
或 Resource.error(.LiveData。 .)
ViewModel 然后将 ApiService 的 LiveData 结果合并到 MediatorLiveData
我的查询:
在单元测试中,只有第一个发射 Resource.loading(..)
是由 ViewModel 中的 MediatorLiveData 生成的。 MediatorLiveData 从不从存储库发出任何数据。
ViewModel.class
private var discoverMovieLiveData: MediatorLiveData<Resource<DiscoverMovieResponse>> = MediatorLiveData()
fun observeDiscoverMovie(): LiveData<Resource<DiscoverMovieResponse>> {
return discoverMovieLiveData
}
fun fetchDiscoverMovies(page: Int) {
discoverMovieLiveData.value = Resource.loading(null) // this emit get observed immediately
val source = movieRepository.fetchDiscoverMovies(page)
discoverMovieLiveData.addSource(source) {
discoverMovieLiveData.value = it // never gets called
discoverMovieLiveData.removeSource(source)
}
}
Repository.class
fun fetchDiscoverMovies(page: Int): LiveData<Resource<DiscoverMovieResponse>> {
return LiveDataReactiveStreams.fromPublisher(
apiService.fetchDiscoverMovies(page)
.subscribeOn(Schedulers.io())
.map { d ->
Resource.success(d) // never gets called in unit test
}
.onErrorReturn { e ->
Resource.error(ApiErrorHandler.getErrorByThrowable(e), null) // // never gets called in unit test
}
)
}
单元测试
@Test
fun loadMovieListFromNetwork() {
val mockResponse = DiscoverMovieResponse(1, emptyList(), 100, 10)
val call: Flowable<DiscoverMovieResponse> = successCall(mockResponse) // wraps the retrofit result inside a Flowable<DiscoverMovieResponse>
whenever(apiService.fetchDiscoverMovies(1)).thenReturn(call)
viewModel.fetchDiscoverMovies(1)
verify(apiService).fetchDiscoverMovies(1)
verifyNoMoreInteractions(apiService)
val liveData = viewModel.observeDiscoverMovie()
val observer: Observer<Resource<DiscoverMovieResponse>> = mock()
liveData.observeForever(observer)
verify(observer).onChanged(
Resource.success(mockResponse) // TEST FAILS HERE AND GETS "Resource.loading(null)"
)
}
Resource 是一个通用的包装器类,用于包装不同场景的数据,例如加载、成功、错误。
class Resource<out T>(val status: Status, val data: T?, val message: String?) {
.......
}
编辑:#1
出于测试目的,我更新了存储库中的 rx 线程以在主线程上运行它。这以 Looper not mocked 异常结束。
fun fetchDiscoverMovies(page: Int): LiveData<Resource<DiscoverMovieResponse>> {
return LiveDataReactiveStreams.fromPublisher(
apiService.fetchDiscoverMovies(page)
.subscribeOn(AndroidSchedulers.mainThread())
.map {...}
.onErrorReturn {...}
)
}
在测试课上,
@ExtendWith(InstantExecutorExtension::class)
class MainViewModelTest {
companion object {
@ClassRule
@JvmField
val schedulers = RxImmediateSchedulerRule()
}
@Test
fun loadMovieListFromNetwork() {
.....
}
}
RxImmediateSchedulerRule.class
class RxImmediateSchedulerRule : TestRule {
private val immediate = object : Scheduler() {
override fun createWorker(): Worker {
return ExecutorScheduler.ExecutorWorker(Executor { it.run() })
}
}
override fun apply(base: Statement, description: Description): Statement {
return object : Statement() {
@Throws(Throwable::class)
override fun evaluate() {
RxJavaPlugins.setInitIoSchedulerHandler { immediate }
RxJavaPlugins.setInitComputationSchedulerHandler { immediate }
RxJavaPlugins.setInitNewThreadSchedulerHandler { immediate }
RxJavaPlugins.setInitSingleSchedulerHandler { immediate }
RxAndroidPlugins.setInitMainThreadSchedulerHandler { immediate }
try {
base.evaluate()
} finally {
RxJavaPlugins.reset()
RxAndroidPlugins.reset()
}
}
}
}
}
InstantExecutorExtension.class
class InstantExecutorExtension : BeforeEachCallback, AfterEachCallback {
override fun beforeEach(context: ExtensionContext?) {
ArchTaskExecutor.getInstance().setDelegate(object : TaskExecutor() {
override fun executeOnDiskIO(runnable: Runnable) {
runnable.run()
}
override fun postToMainThread(runnable: Runnable) {
runnable.run()
}
override fun isMainThread(): Boolean {
return true
}
})
}
override fun afterEach(context: ExtensionContext?) {
ArchTaskExecutor.getInstance().setDelegate(null)
}
}
最佳答案
您指定 RxImmediateSchedulerRule
的方式不适用于 JUnit5。如果您在 apply()
方法中放置一个断点,您将看到它没有被执行。
相反,您应该创建指定的扩展 here :
class TestSchedulerExtension : BeforeTestExecutionCallback, AfterTestExecutionCallback {
override fun beforeTestExecution(context: ExtensionContext?) {
RxJavaPlugins.setIoSchedulerHandler { Schedulers.trampoline() }
RxJavaPlugins.setComputationSchedulerHandler { Schedulers.trampoline() }
RxJavaPlugins.setNewThreadSchedulerHandler { Schedulers.trampoline() }
RxAndroidPlugins.setMainThreadSchedulerHandler { Schedulers.trampoline() }
}
override fun afterTestExecution(context: ExtensionContext?) {
RxJavaPlugins.reset()
RxAndroidPlugins.reset()
}
}
然后在测试类的注释中应用 TestSchedulerExtension
:
@ExtendWith(value = [InstantExecutorExtension::class, TestSchedulerExtension::class])
class MainViewModelTest {
private val apiService: ApiService = mock()
private lateinit var movieRepository: MovieRepository
private lateinit var viewModel: MainViewModel
@BeforeEach
fun init() {
movieRepository = MovieRepository(apiService)
viewModel = MainViewModel(movieRepository)
}
@Test
fun loadMovieListFromNetwork() {
val mockResponse = DiscoverMovieResponse(1, emptyList(), 100, 10, 0, "", false)
val call: Flowable = Flowable.just(mockResponse)
whenever(apiService.fetchDiscoverMovies(1)).thenReturn(call)
viewModel.fetchDiscoverMovies(1)
assertEquals(Resource.success(mockResponse), LiveDataTestUtil.getValue(viewModel.discoverMovieLiveData))
}
}
现在测试将通过。现在您已经进行了测试,该观察者已被分配了预期值。
换个角度:这是单元测试吗?当然不是,因为在这个测试中我们与 2 个单元交互:MainViewModel
和 MovieRepository
。这更符合“集成测试”的术语。如果您模拟了 MoviesRepository
,那么这将是一个有效的单元测试:
@ExtendWith(value = [InstantExecutorExtension::class, TestSchedulerExtension::class])
class MainViewModelTest {
private val movieRepository: MovieRepository = mock()
private val viewModel = MainViewModel(movieRepository)
@Test
fun loadMovieListFromNetwork() {
val mockResponse = DiscoverMovieResponse(1, emptyList(), 100, 10, 0, "", false)
val liveData =
MutableLiveData>().apply { value = Resource.success(mockResponse) }
whenever(movieRepository.fetchDiscoverMovies(1)).thenReturn(liveData)
viewModel.fetchDiscoverMovies(1)
assertEquals(Resource.success(mockResponse), getValue(viewModel.discoverMovieLiveData))
}
}
请注意,MovieRepository
应与 fetchDiscoverMovies()
一起声明为 open
以便能够模拟它。或者你可以考虑使用 kotlin-allopen
插件。
关于android - 使用 LiveData 的 JUnit5 测试不执行订阅者的回调,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/56422249/
我正在试用 Realm 以及包括 LiveData 在内的 Android 架构组件。 我一直在关注 Google 的应用程序架构指南: https://developer.android.com/t
我有两个 DAO、两个存储库和两个 POJO。有什么方法可以创建两个的一个 Livedata?我需要它来为 Recyclerview 制作单个列表。POJO 是类似的对象。 费用库: public c
使用PagedList,这里没有数据库备份,而是内存中的数据列表(称其为CachedDataList),可以通过fetchMore()填充功能。 有了 PositionalDataSource、Dat
我正在创建具有MVVM架构的应用程序,但遇到了一个问题:获取要在View中显示的LiveData列表。 在我的ViewModel中,我有一个getAll()函数,该函数使用Room从数据库中检索字符串
我有一个包含用户列表的 LiveData 对象,我正在尝试将数据传输到另一个 LiveData 对象以在其他地方使用。 我在 Room 中使用 MVVM,所以我从数据库和 ViewModel 中获取
我是测试新手,我想学习如何使用 MVVM 模式测试协程。我刚刚关注了 https://github.com/android/architecture-samples 项目并做了一些更改(删除了远程源)
我在存储库类中有一个方法如下,它从本地数据库或网络返回国家列表作为 LiveData: fun loadCountries(): LiveData>> { return object : Ne
official Android developer docs 中的协程 LiveData 示例使用 emit() 给出以下示例: val user: LiveData = liveData {
在文字游戏应用中,我在 Activity 和 fragment 之间共享一个模型: public class MainViewModel extends AndroidViewModel {
我正在尝试对一个 View 进行数据绑定(bind),该 View 应该显示通过 View 模型中的 LiveData 属性公开的数据,但我发现无法将 LiveData 内的对象绑定(bind)到 V
使用 lifecycle-viewmodel-ktx和 lifecycle-livedata-ktx并给出以下示例: ViewModel 实现: class AutocompletionViewMod
我正在尝试合并 Android Architecture GitHub example与数据绑定(bind)。为此,我想我必须在 UserViewModel 中添加一个从 LiveData> 到 Li
我需要将域对象映射到 UI 对象并使用实时分页列表显示。 我试图映射 LiveData>至 LiveData>和 map PositionalDataSource至 PositionalDataSou
假设我们有两个 LiveData 对象: LiveData> fooList; LiveData> barList; 并且可以通过某种方法(或构造函数)将 Foo 转换为 Bar 对象。将具有 Foo
我想使用 MutableLiveData 观察来自 ViewModel 的一些数据。问题是我使用子类和父类,并且与 LiveData 存在一些不兼容。我想在 Kotlin 中做的事情的一个例子: im
在 Java 中,我们访问 Livedata> 的第一个元素书籍使用 books[0] ,如何在 Kotlin 中做到这一点? 我已经尝试了一切。 //Java代码 books[0]; // Kotl
我阅读了许多关于 viewmodel 和 livedata 的教程,但我并没有在 mvvm 模式的 viewmodel 类中实际使用 livedata。提前致谢。 最佳答案 Android 开发人员通
我正在创建一个 TODO 列表应用程序,用户可以在其中添加要执行的任务。任务有几类。我有以下情况: viewModelMainActivity = new ViewModelProvi
我正在使用 Kotlin 和 Android 架构组件(LiveData 和 Room)制作一个 Android 应用。 我有一个显示用户的 Activity (存储在数据库中并使用带有 ViewMo
我在我的存储库中使用 AsyncTask,它用于设置存储库中的 LiveData。我如何使用转换从我的 ViewModel 观察这个 LiveData? 最佳答案 你可以忽略我的另一个答案。解决方案是
我是一名优秀的程序员,十分优秀!