4

我们知道LiveData 是生命周期感知的，如果配置更改 LiveData 对象不会每次都从数据库（本地/远程）重新查询，并且只有在数据中有任何更新时才会更新。

最近我开始使用Kotlin Flow，我应该承认它最适合数据层，即在 repo 中实现，以便通知 ViewModel。但是我在 ViewModel/View 层中也使用了Kotlin Flow，以便我collect直接根据其状态（密封类实现）在 Fragment 中的 Flow 对象。我在使用 Flow 时遇到的问题是每次从数据库（本地/远程）检索配置更改数据时。

在这种情况下应该怎么做？有没有办法避免在使用 Flow 时重新查询，或者我应该只在 ViewModel/View Layer 中使用 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)
}

视图模型：

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
4

4 回答 4

2

实际上有一个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.
 }

为了最佳实践，

  • 回购 <-> ViewModel -- 流
  • ViewModel <-> View -- LiveData
于 2021-05-18T01:18:16.840 回答
0

我最近使用 mvi arch 实现进行了一个 repo，因此根据您的要求，我强烈建议您使用

addRepeatingJob(Lifecycle.State.STARTED) {
        viewModel.viewState.collect(::render)
    }

render是一个基于状态的通勤和更新 UI 的功能。其中viewState是一个StateFlow<Status<List>>，在viewModel中实现handle data response，根据数据获取更新ui状态。

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

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

我希望它会很有用。

于 2021-05-17T18:15:20.667 回答
0

可能有点晚了，但有人可能会发现这个答案很有用。如果您在 ViewModel 上使用 LiveData，LiveData 会缓存旋转时的数据，并且相同的数据将填充到视图中，因此不会对数据源进行新的调用。

然而，如果您使用普通 Flow，默认情况下它没有缓存功能，因此在轮换时，它将调用数据源。我想这发生在你的场景中。

于 2021-07-06T14:34:16.493 回答
0

据我所知，如果不包装视图模型中的流程，您将无法做到这一点。在您的示例中，ViewModel 不保留真实状态，而只是转发流，因此您不会从配置更改中获得任何好处。

为您的用例建议的架构是将流映射到视图模型内的 liveData。m0skit0 参考链接 ( https://www.youtube.com/watch?v=B8ppnjGPAGE ) 中的视频显示了 lifeData 构建器的用法。

在您的情况下，这很简单：

class MyViewModel(application: Application): AndroidViewModel(application) 
{
  private val db = LocalDatabase.getInstance(application)
  private val repo = Repo(db)

  val usersData = liveData {
    emit(repo.retrieveUsersData(dataCollectionType))
  }
}
于 2021-04-16T06:48:37.703 回答