Android DataStore结合Flow修改后无法实时获取更新问题

使用DataStore结合Flow时，修改DataStore后无法通过Flow获取更新。首次收集数据时onEach会触发，但修改后不再触发，必须重启应用才能看到最新值。

相关代码如下：

Store.kt #

private class IStore(private val context: Context): Store {
    val eventIDKey = stringPreferencesKey("EventID")

    override suspend fun setEventID(eventID: String) {
        context.dataStoreSettings.edit { settings ->
            settings[eventIDKey] = eventID
        }
    }

    override fun getEventID(): Flow<String> {
        return context.dataStoreSettings.data.map { settings -> settings[eventIDKey].orEmpty() }
    }
}

EventService.kt #

fun getSelectedEventLive() = store.getEventID()
    .onEach { Log.d("EventService", "income new event id $it") }
    .flatMapConcat { if(it.isNotBlank()) eventDao.get(it) else flowOf(null) }

MainViewModel.kt #

val selectedEvent = eventService.getSelectedEventLive()
    .stateIn(viewModelScope, SharingStarted.Lazily, null)

Compose 调用代码 #

val currentEvent by mainViewModel.selectedEvent.collectAsState()

• 核心问题：DataStore实例不唯一
  DataStore必须保证全局单例，如果你每次获取context.dataStoreSettings都是新创建的实例，那修改操作和监听操作对应的是不同的DataStore对象，自然收不到更新。确保你的DataStore初始化是单例模式，比如使用Android官方推荐的扩展属性方式：

  // 在顶级文件中定义，确保全局唯一
  val Context.dataStoreSettings by preferencesDataStore(name = "settings")
  

  所有使用dataStoreSettings的地方，都必须调用同一个Context的这个扩展属性，避免手动创建多个实例。

• 验证修改是否生效
  在调用setEventID后，立刻读取DataStore的值验证是否更新：

  suspend fun checkEventID() {
      val latestID = context.dataStoreSettings.data.first()[eventIDKey].orEmpty()
      Log.d("StoreCheck", "Latest EventID: $latestID")
  }
  

  如果这里能读到新值，但Flow没触发，那100%是实例不唯一的问题。

• 排查Flow转换的影响
  虽然你的onEach没触发，说明问题出在getEventID()返回的Flow上，但如果DataStore实例没问题，可以临时简化getSelectedEventLive()的逻辑，去掉flatMapConcat直接返回getEventID()，看修改后是否能触发onEach，以此排除Room Flow的干扰。

内容的提问来源于stack exchange，提问作者Rofie Sagara