如何解决异步操作未按预期执行 - Kotlin Android
我编写了一个代码来从 Cloud Firestore 获取数据,并且正在尝试使用协程来实现网络调用。我尽量按照官方的指导去做,但由于那些文档中的功能不完整,我根据我的要求做了一些调整,但这些可能是问题本身。
这是获取数据的函数:
suspend fun fetchHubList(): MutableLiveData<ArrayList<HubModel>> = withContext(Dispatchers.IO) {
val hubList = ArrayList<HubModel>()
val liveHubData = MutableLiveData<ArrayList<HubModel>>()
hubsListCollection.get().addOnSuccessListener { collection ->
if (collection != null) {
Log.d(TAG,"Data fetch successful!")
for (document in collection) {
Log.d(TAG,"the document id is ")
hubList.add(document.toObject(HubModel::class.java))
}
} else {
Log.d(TAG,"No such document")
}
}.addOnFailureListener { exception ->
Log.d(TAG,"get failed with ",exception)
}
if (hubList.isEmpty()) {
Log.d(TAG,"Collection size 0")
} else {
Log.d(TAG,"Collection size not 0")
}
liveHubData.postValue(hubList)
return@withContext liveHubData
}
这是调用此方法的 ViewModel 类:
class HubListViewModel(application: Application): AndroidViewModel(application) {
// The data which will be observed
var hubList = MutableLiveData<ArrayList<HubModel>>()
private val hubListDao = HubListDao()
init {
viewModelScope.launch (Dispatchers.IO){
hubList = hubListDao.fetchHubList()
Log.d(TAG,"Array List fetched")
}
}
}
使用标签消息我知道正在返回一个空列表,我从另一个 question of mine 知道这是因为返回的 ArrayList 与获取操作不同步,但我不知道为什么,因为我已经将整个函数包装在一个 with context
块中。请告诉我为什么没有按顺序执行返回和获取。
解决方法
您应该添加此依赖项 "org.jetbrains.kotlinx:kotlinx-coroutines-play-services:1.4.3"
。它允许您使用 await()
来替换回调。
suspend fun fetchHubList(): List<HubModel>? = try {
hubsListCollection.get().await().map { document ->
Log.d(TAG,"the document id is ${document.id}")
document.toObject(HubModel::class.java)
}.apply {
Log.d(TAG,"Data fetch successful!")
Log.d(TAG,"Collection size is $size")
}
} catch (e: Exception) {
Log.d(TAG,"get failed with ",e)
null
}
Dispatchers.IO
不是必需的,因为 firebase API 是主安全的
class HubListViewModel(application: Application): AndroidViewModel(application) {
val hubList = MutableLiveData<List<HubModel>>()
private val hubListDao = HubListDao()
init {
viewModelScope.launch {
hubList.value = hubListDao.fetchHubList()
Log.d(TAG,"List fetched")
}
}
}
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。