Ниже приведен тестовый код для моего ViewModel класса. Моя архитектура приложения основана на MVI. По сути, я пытаюсь издеваться над своим репо и государственными классами. В тестовой функции, которую я написал ниже, я пытаюсь проверить, изменяется ли состояние в правильном порядке, когда я успешно загружаю список новостей из API.
class NewsListViewModelTest {
//...
@get:Rule
val testSchedulerRule = RxTestSchedulerRule()
private lateinit var testSubject: NewsListViewModel
private val loadingState = NewsListState(state = State.LOADING)
private val newsRepo = mock<NewsRepository>()
private val observer = mock<Observer<NewsListState>>()
@Before
fun setUp() {
testSubject = NewsListViewModel(newsRepo)
testSubject.observableState.observeForever(observer)
}
@Test
fun `Given news list successfully loaded, when action LoadNewsList is received, then state contains news list`() {
// GIVEN
val newsList = listOf(News("title", "description", Date(), "image"))
val successState = NewsListState(newsList = newsList, state = State.DATA)
whenever(newsRepo.loadAll("keyword", 1, 1))
.thenReturn(Observable.just(newsList))
// WHEN
testSubject.dispatch(NewsListAction.LoadNewsList("keyword"))
testSchedulerRule.triggerActions()
// THEN
inOrder(observer) {
verify(observer).onChanged(loadingState)
verify(observer).onChanged(successState)
}
verifyNoMoreInteractions(observer)
}
}
Однако, когда я запускаю этот тест, я Я получаю следующую ошибку в первой строке внутри inOrder(observer){ ... }:
Wanted but not invoked:
observer.onChanged(
NewsListState(newsList=[], state=LOADING, errorMessage=)
);
-> at [packagename].NewsListViewModelTest.Given news list failed to load, when action LoadNewsList is received, then state contains error(NewsListViewModelTest.kt:77)
Actually, there were zero interactions with this mock.
И это мои тестовые зависимости:
testImplementation 'junit:junit:4.12'
testImplementation 'androidx.arch.core:core-testing:2.1.0'
testImplementation 'com.nhaarman.mockitokotlin2:mockito-kotlin:2.2.0'
В чем может быть причина этой ошибки?
Редактировать - Мой RxTestSchedulerRule класс:
class RxTestSchedulerRule(private val testScheduler: TestScheduler = TestScheduler()) : Scheduler(),
TestRule {
override fun apply(base: Statement, description: Description?): Statement {
RxJavaPlugins.setIoSchedulerHandler { testScheduler }
RxJavaPlugins.setComputationSchedulerHandler { testScheduler }
RxJavaPlugins.setNewThreadSchedulerHandler { testScheduler }
RxJavaPlugins.setSingleSchedulerHandler { testScheduler }
RxAndroidPlugins.setInitMainThreadSchedulerHandler { Schedulers.trampoline() }
return base
}
override fun createWorker() = testScheduler.createWorker()
fun triggerActions() = testScheduler.triggerActions()
}
Редактировать 2 - Моя функция отправки:
fun dispatch(?) {
newsRepository.loadAll(keyword = it.keyword,
pageSize = pageSize,
page = page)
.subscribeOn(Schedulers.io())
.map<NewsListChange> { newsList ->
NewsListChange.Data(newsList) }
.defaultIfEmpty(NewsListChange.Data(emptyList()))
.onErrorReturn { throwable ->
NewsListChange.Error(throwable) }
.startWith(NewsListChange.Loading)
}