如何解决Flow LifeCycle是否知道LiveData?
我们知道 LiveData知道生命周期,并且如果有配置更改,则LiveData对象不会每次都从数据库(本地/远程)中重新查询,并且仅在存在任何情况时才进行更新更新数据。
最近我开始使用 Kotlin Flow ,我应该承认,它最适合数据层,也就是在存储库中实现,以便通知ViewModel。但是我也在ViewModel / View层中使用了 Kotlin Flow ,因此我直接根据其 Status (密封类实现)collect
片段中的Flow对象。我在使用Flow时遇到的问题是每一次从数据库(本地/远程)检索配置更改数据时。
在这种情况下应该怎么做?有没有一种方法可以避免在使用Flow时重新查询,还是应该只在ViewModel / View层中使用LiveData?
示例代码
sealed class Status<T> {
class Processing<T> : Status<T>()
data class Completed<T>(val value: T) : Status<T>()
data class Error<T>(val error: String) : Status<T>()
companion object {
fun <T> processing() = Processing<T>()
fun <T> completed(value: T) = Completed(value)
fun <T> error(error: String) = Error<T>(error)
}
}
回购:
class Repo(database: LocalDatabase){
fun retrieveUsersData() = flow<Status<List<Users>>>{
emit(Status.processing())
database.dao.getUsers().collect{
// Assume db queries successfully and returns list of users
emit(Status.completed(it))
}
}.catch {
emit(Status.error(it.error.toString()))
}.flowOn(Dispatchers.IO)
}
ViewModel:
class MyViewModel(application: Application): AndroidViewModel(application)
{
private val db = LocalDatabase.getInstance(application)
private val repo = Repo(db)
val usersData= repo.retrieveUsersData(dataCollectionType)
}
片段:
class UsersFragment: Fragment(){
override fun onCreateView(
inflater: LayoutInflater,container: ViewGroup?,savedInstanceState: Bundle?
): View? {
// Assume all the declarations are done properly
coroutineScope.launch {
retrieveUsersData()
}
}
private suspend fun retrieveUsersData(){
viewModel.retrieveUsersData().collect{ status ->
// Based on the Status do the actions.
// When Status is Completed set the data to the adapter.
}
}
} // end of Fragment
解决方法
据我所知,如果不包装视图模型中的流程,您就无法做到这一点。在您的示例中,ViewModel 没有保持真实状态,而只是转发流,因此您不会从配置更改中幸存下来获得任何好处。
针对您的用例建议的架构是将流映射到视图模型内的 liveData。链接 m0skit0 引用 (https://www.youtube.com/watch?v=B8ppnjGPAGE) 中的视频展示了 lifeData builder 的用法。
在你的情况下,这很简单:
class MyViewModel(application: Application): AndroidViewModel(application)
{
private val db = LocalDatabase.getInstance(application)
private val repo = Repo(db)
val usersData = liveData {
emit(repo.retrieveUsersData(dataCollectionType))
}
}
,
我最近在一个带有 mvi arch 实现的 repo 上工作,因此根据您的要求,我强烈建议您使用
收集流量addRepeatingJob(Lifecycle.State.STARTED) {
viewModel.viewState.collect(::render)
}
render 是一种基于状态通勤和更新 UI 的功能。
其中viewState是一个StateFlow
您还可以添加一个 dummyState 来处理隐藏视图或意外关闭。
我希望它会很有用。
,实际上有一个 asLiveData()
可以将 Flow 转换为 LiveData。您可以将 viewModelScope.coroutineContext
附加到 Flow,以便 Flow 尊重 ViewModel 的生命周期。这是基于您的代码的示例。
class MyViewModel(application: Application): AndroidViewModel(application)
{
private val db = LocalDatabase.getInstance(application)
private val repo = Repo(db)
val usersData = repo.retrieveUsersData(dataCollectionType).asLiveData(viewModelScope.coroutineContext)
}
然后,像往常一样在您的视图(活动/片段)中观察这个 LiveData。当 ViewModel 被销毁时,这个 Flow(转换为 LiveData)也会被销毁。
viewModel.userData.observe(viewLifecycleOwner,{ status ->
// Based on the Status do the actions.
// When Status is Completed set the data to the adapter.
}
最佳实践,
- Repo ViewModel -- Flow
- ViewModel View -- LiveData
可能有点晚了,但有人可能会发现这个答案很有用。 如果您在 ViewModel 中使用 LiveData,LiveData 会缓存旋转数据, 并且相同的数据将填充到视图中,因此不会有对数据源的新调用。
然而,如果你使用普通的 Flow,默认情况下它没有缓存功能,所以在轮换时,它会调用数据源。 我猜这发生在你的场景中。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。