根据第一个 LiveData 或 Flow 值组合 LiveData 或 Flow

Question

我想有条件地组合两个 livedata / flow 值。这是我的问题：目前，我有两个 livedata / flow 值。一个 LiveData 值始终发出 Status<Unit> 类型，而第二个 LiveData 值发出 T。当第一个 LiveData 值发出 Status.Success 时，我手动将 View 设置为可见，现在知道第二个 LiveData 值将发出 T。

我现在想要的是，在我的第一个 LiveData 值 onSucess 块中获取第二个 Livedata 值 T

目前的做法

class MyViewModel() : ViewModel() {
    val myDownloadState: LiveData<Status<Unit>> = ...
    val myDownloadData: LiveData<T> = ...
}

class MyFragment : Fragment() {
   val myViewModel = ...

   myViewModel.myDownloadState.observeStatus(
       viewLifecycleOwner,
       onSuccess = { it: Unit
          binding.myRecyclerView.isVisible = true
       },
       onLoading = {
          binding.myRecyclerView.isVisible = false
       },
       onError = { it: String?
         toast(it.toString())
       }
   )

   myViewModel.myDownloadData.observe(viewLifecycleOwner) { data: T
       binding.myRecylerView.submitList(data)
   }

}

我想要什么

class MyViewModel() : ViewModel() {
    val myCombinedState: LiveData<Status<T>> = ...
}

class MyFragment : Fragment() {
   val myViewModel = ...

   myViewModel.myCombinedState.observeStatus(
       viewLifecycleOwner,
       onSuccess = { it: T
          binding.myRecyclerView.isVisible = true
          binding.myRecylerView.submitList(data)
       },
       onLoading = {
          binding.myRecyclerView.isVisible = false
       },
       onError = { it: String?
         toast(it.toString())
       }
   )
}

这是两个 livedata 值的来源：

interface IWorkerContract<T, R> {
    // this is "myDownloadData"
    val appDatabaseData: LiveData<R>

    // this is "myDownloadState"
    val workInfo: LiveData<Status<Unit>>
}

@Singleton
class DocumentWorkerContract @Inject constructor(
    @ApplicationContext private val context: Context,
    private val documentDao: DocumentDao,
) : IWorkerContract<Unit, List<DocumentCacheEntity>> {
    // this is "myDownloadData"
    override val appDatabaseData: LiveData<List<DocumentCacheEntity>>
        get() = documentDao.getListLiveData()

    // this is "myDownloadState"
    override val workInfo: LiveData<Status<Unit>>
        get() = WorkManager
            .getInstance(context)
            .getWorkInfoByIdLiveData(worker.id)
            .mapToState()
}

状态类

sealed class Status<out T> {
    data class Success<out T>(val data: T) : Status<T>()
    class Loading<out T>(val message: String? = null) : Status<T>()
    data class Failure<out T>(val message: String?) : Status<T>()

    companion object {
        fun <T> success(data: T) = Success(data)
        fun <T> loading(message: String? = null) = Loading<T>(message)
        fun <T> failed(message: String?) = Failure<T>(message)
    }
}

Answer 1

在这种情况下，我认为您应该尝试将switchMap 与map 结合使用。

试试这个方法：

class MyViewModel() : ViewModel() {

    val myCombineState: LiveData<List<DocumentCacheEntity>> = myDownloadState.switchMap { state ->
        myDownloadData.map { data ->
            when (state) {
                is Status.Success -> {
                    Status.Success(data)
                }
                is Status.Loading -> {
                    Status.Loading()
                }
                is Status.Error -> {
                    Status.Error()  
                }
            }
        }
    }

}