为何两种Kotlin协程读取Firestore列表的方法结果不同？

问题根源 #

MethodA返回空列表的核心问题是错误混用Firestore回调API与Kotlin协程，加上协程逻辑误用：

1. async块内的addOnSuccessListener是异步回调，async会直接执行到最后一行返回空的myList——此时回调还未触发，列表完全没被填充。
2. 最终错误地将Deferred类型的job传给temp.postValue()，而非await()返回的实际列表数据。
3. 原代码中参数type与局部变量type重名，属于潜在语法隐患。

修复后的MethodA代码 #

fun methodA(type: String) {
    CoroutineScope(Dispatchers.IO).launch {
        // 用Firestore协程扩展方法await()替代回调，同步获取查询快照
        val snapshot = db.collection("Products").get().await()
        // 用mapNotNull遍历快照，过滤并转换为Product列表
        val myList = snapshot.mapNotNull { subSnapshot ->
            if (subSnapshot.exists() && subSnapshot["name"]?.equals(type) == true) {
                val category = type
                val url = subSnapshot["url"].toString()
                val itemType = subSnapshot["type"].toString() // 避免变量名重名
                Product(url, category, subSnapshot.id, itemType)
            } else {
                null
            }
        }.toMutableList()
        
        temp.postValue(myList)
    }
}

关键修复说明 #

• 移除回调，改用协程挂起方法：Firestore官方提供了协程扩展，用await()替代addOnSuccessListener，确保快照获取完成后再处理数据，适配协程的挂起逻辑。
• 简化列表填充逻辑：用mapNotNull替代手动遍历添加，既符合Kotlin函数式风格，又避免手动操作可变列表的线程安全风险。
• 修正变量名冲突：将局部变量type改为itemType，避免与方法参数重名导致的逻辑混淆。
• 移除不必要的async：当前场景是单任务异步操作，launch作用域内直接处理挂起函数即可，无需额外使用async。

进阶优化建议 #

• 使用生命周期绑定的协程作用域：避免直接创建CoroutineScope(Dispatchers.IO)，推荐用Android中的viewModelScope或lifecycleScope，防止内存泄漏。
• 封装查询逻辑为独立挂起函数：提高代码复用性，让业务逻辑更清晰：

// 独立的Firestore查询挂起函数
private suspend fun fetchProductsByType(type: String): List<Product> {
    val snapshot = db.collection("Products").get().await()
    return snapshot.mapNotNull { subSnapshot ->
        if (subSnapshot.exists() && subSnapshot["name"] == type) {
            Product(
                url = subSnapshot["url"].toString(),
                category = type,
                id = subSnapshot.id,
                type = subSnapshot["type"].toString()
            )
        } else null
    }
}

// 调用示例
fun methodA(type: String) {
    viewModelScope.launch(Dispatchers.IO) {
        val productList = fetchProductsByType(type)
        temp.postValue(productList)
    }
}

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