Как я могу проверить, какая ошибка возврата списка постраничного списка во время ответа?

Question

Я пытаюсь проверить ошибку в источнике данных PagedList (при загрузке новой группы данных). Мой источник данных выглядит так:

package com.ps.superheroapp.ui.character_screen.list

import androidx.paging.PositionalDataSource
import com.ps.superheroapp.api.MarvelApiService
import com.ps.superheroapp.objects.SchedulerNames
import io.reactivex.Scheduler
import io.reactivex.disposables.CompositeDisposable
import javax.inject.Named

class CharactersDataSource(
    private val compositeDisposable: CompositeDisposable,
    private val marvelApi: MarvelApiService,
    @Named(SchedulerNames.MAIN) private val scheduler: Scheduler,
    private val filter: Filter
) : PositionalDataSource<Character>() {

    var events: SourcedDataEventsHandler? = null

    override fun loadInitial(params: LoadInitialParams, callback: LoadInitialCallback<Character>) {
        compositeDisposable.add(marvelApi.searchCharacter(params.pageSize, 0, filter.searchQuery)
            .observeOn(scheduler)
            .doOnSubscribe {
                events?.onLoadStarted()
            }
            .subscribe({
                callback.onResult(it.data.results ?: arrayListOf(), 0)
                events?.onLoadFinishedSuccessfully()
            }, {
                events?.onLoadFinishedWithError(it)
            })
        )
    }

    override fun loadRange(params: LoadRangeParams, callback: LoadRangeCallback<Character>) {
        compositeDisposable.add(
            marvelApi.searchCharacter(params.loadSize, params.startPosition, filter.searchQuery)
                .observeOn(scheduler)
                .doOnSubscribe {
                    events?.onLoadStarted()
                }
                .subscribe({
                    callback.onResult(it.data.results ?: arrayListOf())
                    events?.onLoadFinishedSuccessfully()
                }, {
                    events?.onLoadFinishedWithError(it)
                })
        )
    }
}

Если я просто буду имитировать класс обработчика событий и во время теста вызову из него методы, этот тест ничего не будет тестировать.

Я искал способы или лучшие практики для проверки этого типа поведения, но я ничего не нашел.

Мой тест выглядит так:

@Test
fun should_show_network_error_when_screen_data_cannot_be_loaded_because_of_internet_connection() {
`when`(connectivityChecker.isOffline()).thenReturn(true)
    //logic to imitate error during loading from data source

    vm.fetchCharacters()

    Assert.assertEquals(ErrorType.NETWORK, vm.error.get())
}

Не могли бы вы дать мне несколько советов или архитектурный пример, или пример модульного теста, чтобы проверить это. заранее спасибо

Answer 1

Я нашел следующее решение, которое является работой:

Я изменил интерфейс обратного вызова на PublishSubject в источнике данных:

class CharactersDataSource(
    private val compositeDisposable: CompositeDisposable,
    private val marvelApi: MarvelApiService,
    @Named(SchedulerNames.MAIN) private val scheduler: Scheduler,
    val filter: Filter
) : PositionalDataSource<Character>() {

    private val onEvent = PublishSubject.create<CharacterLoadEvent>()

    override fun loadInitial(params: LoadInitialParams, callback: LoadInitialCallback<Character>) {
        compositeDisposable.add(marvelApi.searchCharacter(params.pageSize, 0, filter.searchQuery)
            .observeOn(scheduler)
            .doOnSubscribe {
                onEvent.onNext(CharacterLoadEvent.LOAD_STARTED)
            }
            .subscribe({
                callback.onResult(it.data.results ?: arrayListOf(), 0)
                onEvent.onNext(CharacterLoadEvent.LOADED)
            }, {
                onEvent.onNext(CharacterLoadEvent.ERROR)
            })
        )
    }

    override fun loadRange(params: LoadRangeParams, callback: LoadRangeCallback<Character>) {
        compositeDisposable.add(
            marvelApi.searchCharacter(params.loadSize, params.startPosition, filter.searchQuery)
                .observeOn(scheduler)
                .doOnSubscribe {
                    onEvent.onNext(CharacterLoadEvent.LOAD_STARTED)
                }
                .subscribe({
                    callback.onResult(it.data.results ?: arrayListOf())
                    onEvent.onNext(CharacterLoadEvent.LOADED)
                }, {
                    onEvent.onNext(CharacterLoadEvent.ERROR)
                })
        )
    }

    fun observeCharactersLoadEvents(): Observable<CharacterLoadEvent> = onEvent
}

и в тестах издевается над поведением этого издателя. Пара тестов выглядит так:

@Test
    fun should_show_network_error_when_screen_data_cannot_be_loaded_because_of_internet_connection() {
        `when`(connectivityChecker.isOffline()).thenReturn(true)
        `when`(interactor.observeCharactersLoadEvents()).thenReturn(Observable.just(CharacterLoadEvent.ERROR))
        `when`(interactor.getCharacters()).then {
            TestPageList.get<Character>(listOf())
        }

        vm.fetchCharacters()

        Assert.assertEquals(ErrorType.NETWORK, vm.error.get())
    }

    @Test
    fun should_show_general_error_when_screen_data_cannot_be_loaded_because_of_unknown_error() {
        `when`(connectivityChecker.isOffline()).thenReturn(false)
        `when`(interactor.observeCharactersLoadEvents()).thenReturn(Observable.just(CharacterLoadEvent.ERROR))

        vm.fetchCharacters()
        Assert.assertEquals(ErrorType.GENERAL, vm.error.get())
    }

    @Test
    fun should_filter_character_list_when_user_enter_text_in_search_field() {
        `when`(interactor.observeCharactersLoadEvents()).thenReturn(Observable.just(CharacterLoadEvent.LOAD_STARTED))
        `when`(interactor.getCharacters()).then {
            TestPageList.get<Character>(listOf())
        }

        vm.searchQuery.value = "Hulk"

        Mockito.verify(interactor, times(1)).getCharacters("Hulk")
    }

Это может помочь проверить поведение Data Source, и это работает для меня. Я также буду очень признателен за любую идею, как улучшить эту архитектуру / подход / тест