android协程流程手动重试

Question

我在 viewModel 中使用 stateFlow 来获取带有密封类的 api 调用的结果，如下所示：

sealed class Resource<out T> {
    data class Loading<T>(val data: T?): Resource<T>()
    data class Success<T>(val data: T?): Resource<T>()
    data class Error<T>(val error: Exception, val data: T?, val time: Long = System.currentTimeMillis()): Resource<Nothing>()
}

class VehicleViewModel @ViewModelInject constructor(application: Application, private val vehicleRepository: VehicleRepository): BaseViewModel(application) {

    val vehiclesResource: StateFlow<Resource<List<Vehicle>>> = vehicleRepository.getVehicles().shareIn(viewModelScope, SharingStarted.Eagerly, replay = 1)
}

我想在我的 UI 中建议一个按钮，以便如果 api 调用失败，用户可以重试调用。我知道流程上有一个retry方法，但无法手动调用它，因为它仅在发生异常时触发。

一个常见的用例是：用户没有互联网连接，当 api 调用返回网络异常时，我向用户显示一条消息，告诉他检查其连接，然后使用重试按钮（或通过检测设备现在已连接，无论如何），我重试该流程。

但我想不出一种方法来做到这一点，就像你不能那样，比如 call flow.retry()。retry一旦发生异常，就会调用实际的方法。我不想在不要求用户检查其连接的情况下立即重试，这没有意义。

实际上，我发现的唯一解决方案是在按下重试按钮时重新创建活动，以便重置流程，但这当然对性能来说很糟糕。

如果没有流程，解决方案很简单，并且有大量示例，您只需重新启动作业即可，但我找不到一种方法来正确使用流程。我的存储库中有本地房间数据库和远程服务之间的逻辑，并且 flow api 非常好，所以我也想将它用于这个用例。

Answer 1

我建议将 保留vehicleResource为视图模型中的一个字段，并调用一个函数来进行 API 调用以获取数据。

private val _vehiclesResource = MutableStateFlow<Resource<List<Vehicle>>>(Resource.Loading(emptyList()))
val vehiclesResource: StateFlow<Resource<List<Vehicle>>> = _vehiclesResource.asStateFlow()

init {
    fetchVehicles()
}

private var vehicleJob : Job? = null

fun fetchVehicles() {
    vehicleJob?.cancel()

    vehicleJob = viewModelScope.launch {
        vehicleRepository.getVehicles().collect {
            _vehiclesResource.value = it
        }
    }
}

该API将在viewmodel的构造函数中调用。您还可以通过视图（按钮的单击侦听器）调用此函数以获取错误状态。

PS：我应该提到您的这行代码有问题，SharedFlow 无法转换为 StateFlow。

val vehiclesResource: StateFlow<Resource<List<Vehicle>>> = vehicleRepository.getVehicles().shareIn(viewModelScope, SharingStarted.Eagerly, replay = 1)