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>，在viewModel中实现handle数据响应，根据数据获取更新ui状态。

您还可以添加一个 dummyState 来处理隐藏视图或意外关闭。

看看https://github.com/DwanZ/archMigrationExample/blob/mvi/app/src/main/java/com/example/archmigrationexample/view/home/ui/HomeViewModel.kt

我希望它会很有用。

,

实际上有一个 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，默认情况下它没有缓存功能，所以在轮换时，它会调用数据源。 我猜这发生在你的场景中。