Как смоделировать и протестировать RxJava / RxAndroid с помощью Mockk?

Question

Я хочу смоделировать и протестировать мой Presenter с Observable, но я не знаю, как это сделать, основная часть кода, как показано ниже:

//in my presenter:
override fun loadData(){
    this.disposable?.dispose()
    this.disposable = 
        Observable.create<List<Note>> {emitter->
            this.notesRepository.getNotes {notes->
                emitter.onNext(notes)
            }
        }
            .doOnSubscribe {
                this.view.showProgress()
            }
            .subscribe {
                this.view.hideProgress()
                this.view.displayNotes(it)
            }
}

//in test:
@Test
fun load_notes_from_repository_and_display(){
    val loadCallback = slot<(List<Note>)->Unit>();
    every {
        notesRepository.getNotes(capture(loadCallback))
    } answers {
        //Observable.just(FAKE_DATA)
        loadCallback.invoke(FAKE_DATA)
    }
    notesListPresenter.loadData()
    verifySequence {
        notesListView.showProgress()
        notesListView.hideProgress()
        notesListView.displayNotes(FAKE_DATA)
    }
}

Я получил ошибку: Verification failed: call 2 of 3: IView(#2).hideProgress()) was not called.

Итак, как протестировать Rx-вещи с помощью Mockk в модульном тестировании Android? Заранее спасибо!

Answer 1

Добавьте RxImmediateSchedulerRule из https://github.com/elye/demo_rxjava_manage_state,, затем используйте spyk вместо mockk, и это работает!

companion object
{
    @ClassRule @JvmField
    val schedulers = RxImmediateSchedulerRule()
}

@Test
fun load_notes_from_repository_and_display()
{
    val loadCallback = slot<(List<Note>)->Unit>();
    val notesRepo = spyk<INotesRepository>()
    val notesView = spyk<INotesListContract.IView>()
    every {
        notesRepo.getNotes(capture(loadCallback))
    } answers {
        loadCallback.invoke(FAKE_DATA)
    }

    val noteList = NotesListPresenter(notesRepo, notesView)
    noteList.loadData()

    verifySequence {
        notesView.showProgress()
        notesView.hideProgress()
        notesView.displayNotes(FAKE_DATA)
    }
}