From 4a7567f288cb5a5f259f012e3f9aed0d50a038a5 Mon Sep 17 00:00:00 2001 From: InsanusMokrassar Date: Mon, 30 Jan 2023 23:59:19 +0600 Subject: [PATCH] Update AutoRecacheWriteCRUDRepo.kt --- .../repos/cache/fallback/crud/AutoRecacheWriteCRUDRepo.kt | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/repos/cache/src/commonMain/kotlin/dev/inmo/micro_utils/repos/cache/fallback/crud/AutoRecacheWriteCRUDRepo.kt b/repos/cache/src/commonMain/kotlin/dev/inmo/micro_utils/repos/cache/fallback/crud/AutoRecacheWriteCRUDRepo.kt index 19632663e21..9a044ab254d 100644 --- a/repos/cache/src/commonMain/kotlin/dev/inmo/micro_utils/repos/cache/fallback/crud/AutoRecacheWriteCRUDRepo.kt +++ b/repos/cache/src/commonMain/kotlin/dev/inmo/micro_utils/repos/cache/fallback/crud/AutoRecacheWriteCRUDRepo.kt @@ -5,6 +5,7 @@ import dev.inmo.micro_utils.coroutines.subscribeSafelyWithoutExceptions import dev.inmo.micro_utils.repos.UpdatedValuePair import dev.inmo.micro_utils.repos.WriteCRUDRepo import dev.inmo.micro_utils.repos.cache.cache.FullKVCache +import dev.inmo.micro_utils.repos.cache.FallbackCacheRepo import dev.inmo.micro_utils.repos.set import dev.inmo.micro_utils.repos.unset import kotlinx.coroutines.CoroutineScope @@ -18,7 +19,7 @@ open class AutoRecacheWriteCRUDRepo( protected val scope: CoroutineScope, protected val kvCache: FullKVCache = FullKVCache(), protected val idGetter: (RegisteredObject) -> Id -) : WriteCRUDRepo { +) : WriteCRUDRepo, FallbackCacheRepo { override val deletedObjectsIdsFlow: Flow get() = (originalRepo.deletedObjectsIdsFlow + kvCache.onValueRemoved).distinctUntilChanged() override val newObjectsFlow: Flow