Paging3: вызов refresh () на адаптере не запускает обновление при возврате из другого фрагмента

Question

Я использую последнюю версию библиотеки Paging3 для своего приложения, в которой есть экран галереи, отображающий список фотографий, и экран сведений, на котором отображаются дополнительные параметры и информация о фотографии. Я настроил галерею, чтобы получить список фотографий в моем фрагменте onCreate:

    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)

        // display all photos, sorted by latest
        viewModel.getAllPhotos()
    }

В случае успеха фотографии передаются в адаптер через submitList, и если пользователь откроет экран галереи, это должно вызвать обновление, поэтому я установил refreshListenerсоответственно. Я делаю это на onViewCreated(обратите внимание, что я использую ViewBinding):

    override fun onViewCreated(view: View, savedInstanceState: Bundle?) {
        super.onViewCreated(view, savedInstanceState)
        binding = FragmentGalleryBinding.bind(view)

        viewLifecycleOwner.lifecycle.addObserver(viewModel)

        setupGallery()

        setupRetryButton()
    }

    private fun setupGallery() {
        // Add a click listener for each list item
        adapter = GalleryAdapter{ photo ->
            photo.id.let {
                findNavController().navigate(GalleryFragmentDirections.detailsAction(it))
            }
        }

        viewModel.uiState?.observe(viewLifecycleOwner, {
            binding?.swipeLayout?.isRefreshing = false
            adapter.submitData(lifecycle, it)
        })

        binding?.apply {
            // Apply the following settings to our recyclerview
            list.adapter = adapter.withLoadStateHeaderAndFooter(
                header = RetryAdapter {
                    adapter.retry()
                },
                footer = RetryAdapter {
                    adapter.retry()
                }
            )

            // Add a listener for the current state of paging
            adapter.addLoadStateListener { loadState ->
                Log.d("GalleryFragment", "LoadState: " + loadState.source.refresh.toString())
                // Only show the list if refresh succeeds.
                list.isVisible = loadState.source.refresh is LoadState.NotLoading
                // do not show SwipeRefreshLayout's progress indicator if LoadState is NotLoading
                swipeLayout.isRefreshing = loadState.source.refresh !is LoadState.NotLoading
                // Show loading spinner during initial load or refresh.
                progressBar.isVisible = loadState.source.refresh is LoadState.Loading && !swipeLayout.isRefreshing
                // Show the retry state if initial load or refresh fails.
                retryButton.isVisible = loadState.source.refresh is LoadState.Error

                val errorState = loadState.source.append as? LoadState.Error
                    ?: loadState.source.prepend as? LoadState.Error
                    ?: loadState.append as? LoadState.Error
                    ?: loadState.prepend as? LoadState.Error
                errorState?.let {
                    swipeLayout.isRefreshing = false
                    Snackbar.make(requireView(),
                        "\uD83D\uDE28 Wooops ${it.error}",
                        Snackbar.LENGTH_LONG).show()
                }
            }

            swipeLayout.apply {
                setOnRefreshListener {
                    isRefreshing = true
                    adapter.refresh()
                }
            }
        }

При первой загрузке развертывание макета успешно запускает обновление. Однако проблема возникает после того, как я перейду к экрану сведений. На экране сведений нажатие кнопки "Назад" возвращает пользователя в галерею. Если пользователь вытягивает макет, отображается индикатор выполнения, но adapter.refresh()не бывает. Я не понимаю, как это отладить.

Для справки вот как мои ViewModel ответственный за получение фотографий выглядит так:

class GalleryViewModel(private val getAllPhotosUseCase: GetAllPhotosUseCase): BaseViewModel() {

    private val _uiState = MutableLiveData<PagingData<UnsplashPhoto>>()
    val uiState: LiveData<PagingData<UnsplashPhoto>>? get() = _uiState

    fun getAllPhotos() {
        compositeDisposable += getAllPhotosUseCase.getAllPhotos()
            .cachedIn(viewModelScope)
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribeBy(
                onNext = { _uiState.value = it },
                onError = {
                    it.printStackTrace()
                }
            )
    }

}

В GetAllPhotosUseCase направляет getAllPhotos позвонить в Repository реализация, содержащая следующее:

class UnsplashRepoImpl(private val unsplashApi: UnsplashApi): UnsplashRepo {

    override fun getAllPhotos(): Observable<PagingData<UnsplashPhoto>> = Pager(
        config = PagingConfig(Const.PAGE_SIZE),
        remoteMediator = null,
        // Always create a new UnsplashPagingSource object. Failure to do so would result in a
        // IllegalStateException when adapter.refresh() is called--
        // Exception message states that the same PagingSource was used as the prev request,
        // and a new PagingSource is required
        pagingSourceFactory = { UnsplashPagingSource(unsplashApi) }
    ).observable

....
}

Мой RxPagingSource настроен так:

class UnsplashPagingSource (private val unsplashApi: UnsplashApi)
    : RxPagingSource<Int, UnsplashPhoto>(){

    override fun loadSingle(params: LoadParams<Int>): Single<LoadResult<Int, UnsplashPhoto>> {
        val id = params.key ?: Const.PAGE_NUM
        return unsplashApi.getAllPhotos(id, Const.PAGE_SIZE, "latest")
        .subscribeOn(Schedulers.io())
            .map { response ->
                response.map { it.toUnsplashPhoto() }
            }
            .map<LoadResult<Int, UnsplashPhoto>> { item ->
                LoadResult.Page(
                    data = item,
                    prevKey = if (id == Const.PAGE_NUM) null else id - 1,
                    nextKey =  if (item.isEmpty()) null else id + 1
                )
            }
            .onErrorReturn { e -> LoadResult.Error(e) }
    }
}

Может ли кто-нибудь указать мне в правильном направлении?

РЕДАКТИРОВАТЬ: Как сказал Джей Дангар, перемещение viewModel.getAllPhotos() к onResume позвонил бы adapter.refresh()запускается успешно. Однако я не хочу получать все фотографии каждый раз, когда перехожу с экрана сведений в галерею. Чтобы этого избежать, вместо вызова adapter.refresh() когда раскладывается, я просто звоню viewModel.getAllPhotos() вместо.

Я до сих пор не понимаю, почему принятый ответ работает, но предполагаю, что adapter.refresh() работает только при новом PagingSource создается что ли.

Answer 1

Поместите свою логику ссылок в onResume() вместо onCreate(), это проблема управления жизненным циклом.