Get refresh key function overridden by paging data sources.

metinozcura · Feb 1, 2021 · 7d08e88 · 7d08e88
1 parent 6ba6ac4
commit 7d08e88
Show file tree

Hide file tree

Showing 4 changed files with 13 additions and 0 deletions.
diff --git a/...in/java/com/metinozcura/rickandmorty/data/paging/datasource/CharactersPagingDataSource.kt b/...in/java/com/metinozcura/rickandmorty/data/paging/datasource/CharactersPagingDataSource.kt
@@ -2,6 +2,7 @@ package com.metinozcura.rickandmorty.data.paging.datasource
 
 import android.net.Uri
 import androidx.paging.PagingSource
+import androidx.paging.PagingState
 import com.metinozcura.rickandmorty.data.model.Character
 import com.metinozcura.rickandmorty.data.service.CharacterApi
 
@@ -30,4 +31,6 @@ class CharactersPagingDataSource(private val service: CharacterApi) :
             LoadResult.Error(e)
         }
     }
+
+    override fun getRefreshKey(state: PagingState<Int, Character>): Int = 1
 }
diff --git a/...main/java/com/metinozcura/rickandmorty/data/paging/datasource/EpisodesPagingDataSource.kt b/...main/java/com/metinozcura/rickandmorty/data/paging/datasource/EpisodesPagingDataSource.kt
@@ -2,6 +2,7 @@ package com.metinozcura.rickandmorty.data.paging.datasource
 
 import android.net.Uri
 import androidx.paging.PagingSource
+import androidx.paging.PagingState
 import com.metinozcura.rickandmorty.data.model.Episode
 import com.metinozcura.rickandmorty.data.service.EpisodeApi
 
@@ -31,4 +32,6 @@ class EpisodesPagingDataSource(private val service: EpisodeApi) :
             LoadResult.Error(e)
         }
     }
+
+    override fun getRefreshKey(state: PagingState<Int, Episode>): Int = 1
 }
diff --git a/...main/java/com/metinozcura/rickandmorty/data/paging/datasource/LocationPagingDataSource.kt b/...main/java/com/metinozcura/rickandmorty/data/paging/datasource/LocationPagingDataSource.kt
@@ -2,6 +2,7 @@ package com.metinozcura.rickandmorty.data.paging.datasource
 
 import android.net.Uri
 import androidx.paging.PagingSource
+import androidx.paging.PagingState
 import com.metinozcura.rickandmorty.data.model.Location
 import com.metinozcura.rickandmorty.data.service.LocationApi
 
@@ -31,4 +32,6 @@ class LocationPagingDataSource(private val service: LocationApi) :
             LoadResult.Error(e)
         }
     }
+
+    override fun getRefreshKey(state: PagingState<Int, Location>): Int = 1
 }
diff --git a/...ain/java/com/metinozcura/rickandmorty/data/paging/remotemediator/EpisodeRemoteMediator.kt b/...ain/java/com/metinozcura/rickandmorty/data/paging/remotemediator/EpisodeRemoteMediator.kt
@@ -4,10 +4,14 @@ import androidx.paging.ExperimentalPagingApi
 import androidx.paging.LoadType
 import androidx.paging.PagingState
 import androidx.paging.RemoteMediator
+import com.metinozcura.rickandmorty.data.db.AppDB
 import com.metinozcura.rickandmorty.data.model.Episode
+import javax.inject.Inject
 
 @OptIn(ExperimentalPagingApi::class)
 class EpisodeRemoteMediator: RemoteMediator<Int, Episode>() {
+    @Inject lateinit var db: AppDB
+
     override suspend fun load(
         loadType: LoadType,
         state: PagingState<Int, Episode>