标签: android-paging-3

我正在使用分页撰写库使用远程中介（由本地房间数据库支持）从服务器加载分页数据。有没有办法在滑动刷新的情况下手动刷新中介数据？

我正在使用MVVM干净的架构编写应用程序。在其中一个屏幕上，我需要使用 来RecyclerView实现pagination。我要使用图书馆Paging3。

Android 开发者建议在存储库层使用PagingSource和。RemoteMediator但同时，在许多来源中，我读到数据层和领域层不应该了解有关android框架的任何信息。

但现在我必须在数据层的数据源中使用android库。这在 a 的上下文中正确吗clean architecture？

请帮我弄清楚，我不明白如何使用干净的架构实现分页。

我正在按照此Codelab使用 github API 和本地数据库构建 paging3 应用程序。虽然前 2 个页面加载良好，但当滚动到底部时尝试加载第 3 个页面时，调解器会遇到循环 - 相同的 PagingState 一遍又一遍地传递给 load() 函数。

只是想知道是否有人知道这里可能的根本原因是什么？

一些实施细节：

RemoteMediator：（prevPage 和 currentPage 来自 github API 的分页响应标头并保存到本地数据库。）

// RepositoryMediator
override suspend fun load(
    loadType: LoadType,
    state: PagingState<Int, Repository>
): MediatorResult {
    return when (loadType) {
        LoadType.REFRESH -> {
            fireRequestForPage(1, true /*clear DB*/)
            return Success(endOfPaginationReached = false)
        }

        LoadType.APPEND -> {
            // !!!!!!! kept getting the same state when APPEND is triggered, resulting in same currentPage and nextPage …

我正在尝试使用Paging 3库来获取Flow<PagingData<Scan>>，Room然后检查是否在 recyclerview 中选择了项目，因此我将此类映射到另一个名为 的类ScanMapper。为了实现此映射，每当用户将某个项目标记为选定时，我都会Map在MutableStateFlow<Map<Int, State>>. 这里Map查找 anIndex(Int)得到State，State只是一个enum代表 State 的类UNINITIALISED，USELECTED并且SELECTED。

我将 Map 的值设置为 a StateFlow<Map<Int,State>>。问题是，我试图将Flow<PagingData<Scan>>与 结合起来，StateFlow<Map<Int,State>>以便将 也State作为参数传递给ScanMapper类，因为它State是从 中获取的StateFlow<Map<Int,State>>，而不是原始Scan类的一部分。但是，尽管当我使用该功能将项目标记为在项目单击上选择时，PagingDataAdapter似乎总是会出现这种情况。State UNINITIALISEDmarkSelected(scanId: Int)

请告诉我我在这里缺少什么。

更新

我能够通过使用并使用回收器适配器Flow<List<Scan>>删除库的使用来实现我想要的功能。虽然这不是实际的解决方案，因为它消除了库，但以下更改允许我执行项目选择：Paging 3DiffUtilspagination using paging 3

更新了刀 …

我在尝试向 NewsApi.org api 发出获取请求时收到以下错误。根据他们的文档，一切似乎都是正确的，我的设置基本上与很多教程和我在 github 上找到的一些示例相同。

E/AndroidRuntime: FATAL EXCEPTION: main
    Process: com.example.newsfeed, PID: 12360
    java.lang.IllegalArgumentException: Unable to create call adapter for class java.lang.Object
        for method NewsApi.getBreakingNews
        at retrofit2.ServiceMethod$Builder.methodError(ServiceMethod.java:720)
        at retrofit2.ServiceMethod$Builder.createCallAdapter(ServiceMethod.java:234)
        at retrofit2.ServiceMethod$Builder.build(ServiceMethod.java:160)
        at retrofit2.Retrofit.loadServiceMethod(Retrofit.java:166)
        at retrofit2.Retrofit$1.invoke(Retrofit.java:145)
        at java.lang.reflect.Proxy.invoke(Proxy.java:393)
        at $Proxy1.getBreakingNews(Unknown Source)
        at com.example.newsfeed.data.API.NewsApi$DefaultImpls.getBreakingNews$default(NewsApi.kt:11)
        at com.example.newsfeed.util.NewsPagingSource.load(NewsPagingSource.kt:25)
        at androidx.paging.PageFetcherSnapshot.doInitialLoad(PageFetcherSnapshot.kt:275)
        at androidx.paging.PageFetcherSnapshot$pageEventFlow$1.invokeSuspend(PageFetcherSnapshot.kt:160)
        at androidx.paging.PageFetcherSnapshot$pageEventFlow$1.invoke(PageFetcherSnapshot.kt)
        at androidx.paging.CancelableChannelFlowKt$cancelableChannelFlow$1.invokeSuspend(CancelableChannelFlow.kt:30)
        at androidx.paging.CancelableChannelFlowKt$cancelableChannelFlow$1.invoke(CancelableChannelFlow.kt)
        at androidx.paging.SimpleChannelFlowKt$simpleChannelFlow$1$1$producer$1$1.invokeSuspend(SimpleChannelFlow.kt:57)
        at androidx.paging.SimpleChannelFlowKt$simpleChannelFlow$1$1$producer$1$1.invoke(SimpleChannelFlow.kt)
        at kotlinx.coroutines.intrinsics.UndispatchedKt.startUndispatchedOrReturn(Undispatched.kt:91)
        at kotlinx.coroutines.CoroutineScopeKt.coroutineScope(CoroutineScope.kt:194)
        at androidx.paging.SimpleChannelFlowKt$simpleChannelFlow$1$1$producer$1.invokeSuspend(SimpleChannelFlow.kt:52)
        at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33)
        at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:106)
        at kotlinx.coroutines.EventLoop.processUnconfinedEvent(EventLoop.common.kt:69)
        at kotlinx.coroutines.internal.DispatchedContinuationKt.resumeCancellableWith(DispatchedContinuation.kt:357)
        at kotlinx.coroutines.intrinsics.CancellableKt.startCoroutineCancellable(Cancellable.kt:30)
        at kotlinx.coroutines.intrinsics.CancellableKt.startCoroutineCancellable$default(Cancellable.kt:27)
        at kotlinx.coroutines.CoroutineStart.invoke(CoroutineStart.kt:110)
        at …

我正在开发一个 Android Compose 项目，其中使用 Paging 3 和 LazyColumn 来显示从网络调用获取的项目列表。Paging 3 的默认行为是根据prefetchDistance用户滚动来加载页面，但在我的例子中，它会加载大约 15 个页面，每个页面在屏幕启动时包含 10 条记录。我尝试过将其设置prefetchDistace为 10，但不起作用。

这是我的代码： ViewModel

class ShowAllNotificationsViewModel @Inject constructor(private val pagingSource: NotificationPagingSource) :
    BaseViewModel() {


    private val _uiState =
        MutableStateFlow<UIState<BaseResponseModel<NotificationResponseModel?>>>(UIState.StateLoading)
    val uiState = _uiState.asStateFlow()

    private val _isRefreshing = MutableStateFlow(false)
    val isRefreshing = _isRefreshing.asStateFlow()


    val items: Flow<PagingData<NotificationModel>> = Pager(
        config = PagingConfig(
            pageSize = 10,
            prefetchDistance = 5,
            enablePlaceholders = false,
        ),
        pagingSourceFactory = { pagingSource }
    )
        .flow
        .cachedIn(viewModelScope)

    fun refreshData() {
        pagingSource.invalidate() …

使用paging 3.0，我成功地实现了它。现在我想为其添加搜索功能。

我只是显示照片库以及分页功能。现在我想在有人搜索时使分页无效

但每当我在搜索上调用无效时。应用程序崩溃..

照片片段.kt

@AndroidEntryPoint
class PhotosFragment : BaseFragment<FragmentPhotosBinding,PhotosFragmentViewModel>(R.layout.fragment_photos),
    SearchView.OnQueryTextListener, LifecycleObserver {
    override val mViewModel: PhotosFragmentViewModel by viewModels()

    private lateinit var photoAdapter: PhotoCollectionAdapter

    override fun onAttach(context: Context) {
        super.onAttach(context)
        activity?.lifecycle?.addObserver(this)
    }

    override fun onViewCreated(view: View, savedInstanceState: Bundle?) {
        super.onViewCreated(view, savedInstanceState)
        setHasOptionsMenu(true)
        ///mViewModel.setFilter(getString(R.string.search_filter_default_value))
        initAdapter()
    }

    @OnLifecycleEvent(Lifecycle.Event.ON_CREATE)
    fun onCreated(){
        mViewModel.trendingPhotos.observe(viewLifecycleOwner, Observer {
            photoAdapter.submitData(lifecycle,it)
        })
    }

    private fun initAdapter() {
        photoAdapter = PhotoCollectionAdapter()
        photoAdapter.stateRestorationPolicy = RecyclerView.Adapter.StateRestorationPolicy.PREVENT_WHEN_EMPTY

        mBinding.recyclerView.apply {
            layoutManager = LinearLayoutManager(context)
            setHasFixedSize(true)
            adapter = photoAdapter
        }

        photoAdapter.addLoadStateListener { loadState -> …

从自定义分页实现迁移到Jetpack Paging 3 库后，数据未按预期加载。根据以下内容正确处理第一页：PagingConfigPager

internal fun createProductListPager(pagingSource: ProductListPagingSource): Pager<Int, Product> = Pager(
    config = PagingConfig(
        pageSize = 10,
        prefetchDistance = 2,
    ),
    initialKey = 0,
) { pagingSource }

以下是摘录Adapter：

public class PagingProductCardAdapter(private val viewBinder: CoreViewBinder) :
    PagingDataAdapter<Listable, RecyclerView.ViewHolder>(viewBinder.getDiffUtils()) {


    public val list: List<Listable>
        get() = snapshot().items


    override fun onCreateViewHolder(parent: ViewGroup, viewType: Int): RecyclerView.ViewHolder {
      // ...
    }

    override fun onBindViewHolder(holder: RecyclerView.ViewHolder, position: Int) {
        viewBinder.bind(list[position], holder)
    }
    // ...
}

当滚动到 …

我正在使用该Paging 3库，LazyColumn并且我想根据购物清单项目的类别对列表进行排序。在下面的代码中，LazyColumn抱怨它正在期待LazyPagingItems<TypeVariable(T)>该items属性，但发现了List<ShoppingListItem?>。我怎样才能解决这个问题？

可组合的

val lazyListState = rememberLazyListState()
val successItems = allItemsState.allItems?.collectAsLazyPagingItems()

LazyColumn(
    state = lazyListState,
    modifier = Modifier
        .fillMaxWidth(),
    contentPadding = PaddingValues(
        start = 5.dp,
        end = 5.dp,
        top = 8.dp,
        bottom = 165.dp
    ),
    verticalArrangement = Arrangement.spacedBy(5.dp),
) {
    val groupedByCategory = successItems!!.itemSnapshotList.groupBy { it!!.category }

    groupedByCategory.forEach { (initial, shoppingListItems) ->
        item {
            Text(text = initial)
        }
        items(
            items = shoppingListItems, //Throws error at this line
            key …

我已经为我的 android 项目实现了 paging3。为了避免重复的项目，我创建了一个 DiffUtil.ItemCallback 对象，如下所示；

companion object {
    val diffCallback = object : DiffUtil.ItemCallback<Person>() {
        override fun areItemsTheSame(oldItem: Person, newItem: Person): Boolean {
            return oldItem.id == newItem.id
        }

        override fun areContentsTheSame(oldItem: Person, newItem: Person): Boolean {
            return oldItem.id == newItem.id
        }
    }
}

我在 PagingDataAdapter 中使用了该对象；

class PersonAdapter : PagingDataAdapter<Person, PersonViewHolder>(diffCallback) 

在视图中，我从 viewModel 获取 PaginData 并将其提交到适配器中。

    private fun observeData() {
    lifecycleScope.launch {
        viewModel.getPeople().observe(this@MainActivity, {
            pagingAdapter.submitData(lifecycle, it)
        })
    }

在我看来，由于 DiffUtil.ItemCallback，具有相同 id 的人将不会被包含在适配器中。但它没有发生。RecyclerView 会打印每个 person 对象，即使它们具有相同的 id。

如何通过id区分数据？为什么 DiffUtil.ItemCallback 不起作用？谢谢。