使用 Kotlin 协程进行实时 Firestore 更新

Question

从 Firestore 获取一次性数据时，我可以使用 kotlinx-coroutines-play-services 库删除回调：

使用回调

firestore.collection("Users")
    .document(userId)
    .get()
    .addOnSuccessListener { snapshot ->
        // Handle snapshot
    }
    .addOnFailureListener { exception ->
        // Handle exception
    }

使用await() 和协程

try {
    val snapshot = firestore.collection("Users")
        .document(userId)
        .get().await()
    // Handle snapshot
} catch(exception: Exception) {
    // Handle error
}

我正在寻找一种类似的实时更新方法。 addSnapshotListener() 是否有 await() 等效项？

firestore.collection("Users")
    .document(userId)
    .addSnapshotListener { snapshot, exception ->
        // Listen to snapshot in real time
    }

Answer 1

Firestore 侦听器从根本上与协程不兼容，因为它们不会生成单个项目以供消费。您不能“等待”随着时间推移发生的一系列回调（没有明显的终止点）。

映射到听众的最自然的 Kotlin 概念是 flow。流可以随着时间的推移产生一系列值，如果您愿意，可以在协程上下文中使用它们。您必须编写一些代码来将该侦听器转换为流（搜索这些关键字以查看其他人做了什么）。