Lock initial read in onStart (#77)

xxfast · Dec 13, 2023 · d994963 · d994963
1 parent 1ae8888
commit d994963
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/kstore/src/commonMain/kotlin/io/github/xxfast/kstore/KStore.kt b/kstore/src/commonMain/kotlin/io/github/xxfast/kstore/KStore.kt
@@ -28,7 +28,11 @@ public class KStore<T : @Serializable Any>(
   /** Observe store for updates */
   public val updates: Flow<T?>
     get() = this.cache
-      .onStart { read(fromCache = false) } // updates will always start with a fresh read
+      .onStart {
+        lock.withLock {
+          read(fromCache = false)
+        }
+      } // updates will always start with a fresh read
 
   private suspend fun write(value: T?): Unit = withContext(StoreDispatcher) {
     codec.encode(value)