ListenableFuturePagingSource


ListenableFuture-based compatibility wrapper around PagingSource's suspending APIs.

class MyListenableFuturePagingSource(
    val myBackend: GuavaBackendService,
    val searchTerm: String
) : ListenableFuturePagingSource<String, Item>() {
    override fun loadFuture(
        params: LoadParams<String>
    ): ListenableFuture<LoadResult<String, Item>> {
        return myBackend
            .searchUsers(
                searchTerm = searchTerm,
                pageKey = params.key
            )
            .transform<LoadResult<String, Item>>(
                { response ->
                    LoadResult.Page(
                        data = response!!.items,
                        prevKey = response.prev,
                        nextKey = response.next
                    )
                },
                networkExecutor
            )
            // Retrofit calls that return the body type throw either IOException for
            // network failures, or HttpException for any non-2xx HTTP status codes.
            // This code reports all errors to the UI, but you can inspect/wrap the
            // exceptions to provide more context.
            .catching(
                IOException::class.java,
                { t: IOException? -> LoadResult.Error(t!!) },
                networkExecutor
            )
            .catching(
                HttpException::class.java,
                { t: HttpException? -> LoadResult.Error(t!!) },
                networkExecutor
            )
    }

    override fun getRefreshKey(state: PagingState<String, Item>): String? {
        return state.anchorPosition?.let { state.closestItemToPosition(it)?.id }
    }
}

Summary

Public constructors

<Key : Any, Value : Any> ListenableFuturePagingSource()
android

Public functions

open suspend PagingSource.LoadResult<Key, Value>
android
abstract ListenableFuture<PagingSource.LoadResult<Key, Value>>

Loading API for PagingSource.

android

Inherited functions

From androidx.paging.PagingSource
abstract Key?
getRefreshKey(state: PagingState<Key, Value>)
android
Unit
android
Unit
registerInvalidatedCallback(onInvalidatedCallback: () -> Unit)
android
Unit
unregisterInvalidatedCallback(onInvalidatedCallback: () -> Unit)
android

Inherited properties

From androidx.paging.PagingSource
Boolean
android
open Boolean
android
open Boolean
android

Public constructors

ListenableFuturePagingSource

<Key : Any, Value : Any> ListenableFuturePagingSource()

Public functions

load

open suspend fun load(params: PagingSource.LoadParams<Key>): PagingSource.LoadResult<Key, Value>

loadFuture

abstract fun loadFuture(params: PagingSource.LoadParams<Key>): ListenableFuture<PagingSource.LoadResult<Key, Value>>

Loading API for PagingSource.

Implement this method to trigger your async load (e.g. from database or network).