PostDataSource

PostDataSource.kt

package com.rohitjakhar.blogx.repository

import androidx.paging.PagingSource
import androidx.paging.PagingState
import com.rohitjakhar.blogx.model.PostData
import com.rohitjakhar.blogx.repository.remote.RemoteDataSource

class PostDataSource(private val remoteDataSource: RemoteDataSource) :
    PagingSource<Int, PostData>() {

    override fun getRefreshKey(state: PagingState<Int, PostData>): Int? {
        TODO("Not yet implemented")
    }

    override suspend fun load(params: LoadParams<Int>): LoadResult<Int, PostData> {
        try {

            val currentLoadingKey = params.key ?: 1
            val response = remoteDataSource.apicall().getPost(currentLoadingKey)
            val responseData = mutableListOf<PostData>()
            val data = response.body() ?: arrayListOf()
            responseData.addAll(data)

            val prevKey = if (currentLoadingKey == 1) null else currentLoadingKey - 1

            return LoadResult.Page(
                data = responseData,
                prevKey = prevKey,
                nextKey = currentLoadingKey.plus(1)
            )
        } catch (e: Exception) {
            return LoadResult.Error(e)
        }
    }
}