如何在更新Jetpack DataStore前通过Flow读取单次值避免循环？

方案一：用first()仅读取一次当前值 #

DataStore的data Flow是冷流，调用first()会获取当前存储的第一个值，之后自动取消订阅，不会监听后续的写入变化，从根本上避免循环触发。

代码示例（以kotlinx.serialization序列化为例）：

// 定义可序列化的自定义数据类
@Serializable
data class CustomItem(val id: String, val content: String)

// 创建DataStore实例
val dataStore = context.createDataStore(
    name = "custom_items",
    serializer = object : Serializer<List<CustomItem>> {
        override val defaultValue: List<CustomItem> = emptyList()
        override suspend fun readFrom(input: InputStream): List<CustomItem> {
            return try {
                Json.decodeFromString(
                    ListSerializer(CustomItem.serializer()),
                    input.readBytes().decodeToString()
                )
            } catch (e: Exception) {
                defaultValue
            }
        }
        override suspend fun writeTo(t: List<CustomItem>, output: OutputStream) {
            output.write(
                Json.encodeToString(ListSerializer(CustomItem.serializer()), t).encodeToByteArray()
            )
        }
    }
)

// 添加新元素的方法
suspend fun addNewItem(newItem: CustomItem) {
    // 仅读取一次当前列表，读取后自动终止订阅
    val currentList = dataStore.data.first()
    // 更新列表并写入DataStore
    dataStore.updateData { currentList + newItem }
}

方案二：使用updateData原子操作（官方推荐更优方案） #

DataStore自带的updateData方法是原子性操作：内部会自动读取当前存储值，执行你传入的更新逻辑，最后写入新值。整个过程线程安全，无需手动处理Flow订阅，完全规避循环问题。

代码示例：

suspend fun addNewItem(newItem: CustomItem) {
    dataStore.updateData { currentList ->
        // 直接在lambda中获取当前列表，返回更新后的新列表
        currentList + newItem
    }
}

循环问题的根源 #

你之前的写法是订阅dataStore.data的Flow，在collect回调里完成读取、更新、写入操作。而DataStore写入后会向Flow发射新值，再次触发collect逻辑，最终导致无限循环。上面两个方案要么终止一次性订阅，要么用官方原子更新逻辑，都避开了这个触发闭环。

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