GiftedHacker/tangem-app-android-audited
1
0
Fork 0
Code Issues Pull requests Projects Releases 1 Packages Wiki Activity Actions

Updated on 2026-08-14

Browse source
This commit is contained in:
Tangem 2025-04-09 17:14:54 +03:00
commit e73c7b7426
18 changed files with 244 additions and 33 deletions
Download patch file Download diff file Expand all files Collapse all files

12
core/datasource/src/main/java/com/tangem/datasource/local/datastore/RuntimeSharedStore.kt
View file

@ -4,6 +4,8 @@ import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.flow.MutableSharedFlow
import kotlinx.coroutines.flow.firstOrNull
import kotlinx.coroutines.flow.mapNotNull
import kotlinx.coroutines.sync.Mutex
import kotlinx.coroutines.sync.withLock
/**
* Runtime shared store
@ -42,6 +44,7 @@ interface RuntimeSharedStore<T> {
operator fun <T> invoke(): RuntimeSharedStore<T> = object : RuntimeSharedStore<T> {
private val flow = MutableSharedFlow<T?>(replay = 1)
private val updateMutex = Mutex()
init {
flow.tryEmit(value = null)
@ -58,10 +61,13 @@ interface RuntimeSharedStore<T> {
}
override suspend fun update(default: T, function: (T) -> T) {
val storedData = flow.firstOrNull() ?: default
val updatedData = function(storedData)
// required to synchronize get (firstOrNull) and update (emit) operations
updateMutex.withLock {
val storedData = flow.firstOrNull() ?: default
val updatedData = function(storedData)
flow.emit(value = updatedData)
flow.emit(value = updatedData)
}
}
}
}