mirror of
https://github.com/InsanusMokrassar/MicroUtils.git
synced 2025-09-15 21:39:24 +00:00
Update AutoRecacheReadCRUDRepo.kt
This commit is contained in:
@@ -7,6 +7,7 @@ import dev.inmo.micro_utils.repos.ReadCRUDRepo
|
|||||||
import dev.inmo.micro_utils.repos.cache.cache.FullKVCache
|
import dev.inmo.micro_utils.repos.cache.cache.FullKVCache
|
||||||
import dev.inmo.micro_utils.repos.cache.fallback.ActionWrapper
|
import dev.inmo.micro_utils.repos.cache.fallback.ActionWrapper
|
||||||
import dev.inmo.micro_utils.repos.cache.util.actualizeAll
|
import dev.inmo.micro_utils.repos.cache.util.actualizeAll
|
||||||
|
import dev.inmo.micro_utils.repos.cache.FallbackCacheRepo
|
||||||
import dev.inmo.micro_utils.repos.set
|
import dev.inmo.micro_utils.repos.set
|
||||||
import kotlinx.coroutines.CoroutineScope
|
import kotlinx.coroutines.CoroutineScope
|
||||||
import kotlinx.coroutines.delay
|
import kotlinx.coroutines.delay
|
||||||
@@ -21,7 +22,7 @@ open class AutoRecacheReadCRUDRepo<RegisteredObject, Id>(
|
|||||||
protected val recacheDelay: Long = 60.seconds.inWholeMilliseconds,
|
protected val recacheDelay: Long = 60.seconds.inWholeMilliseconds,
|
||||||
protected val actionWrapper: ActionWrapper = ActionWrapper.Direct,
|
protected val actionWrapper: ActionWrapper = ActionWrapper.Direct,
|
||||||
protected val idGetter: (RegisteredObject) -> Id
|
protected val idGetter: (RegisteredObject) -> Id
|
||||||
) : ReadCRUDRepo<RegisteredObject, Id> {
|
) : ReadCRUDRepo<RegisteredObject, Id>, FallbackCacheRepo {
|
||||||
val autoUpdateJob = scope.launch {
|
val autoUpdateJob = scope.launch {
|
||||||
while (isActive) {
|
while (isActive) {
|
||||||
runCatchingSafely {
|
runCatchingSafely {
|
||||||
|
Reference in New Issue
Block a user