时间戳

首页 > 解决方案 > 在 Android 中使用 liveData 取消协程

android - 在 Android 中使用 liveData 取消协程

问题描述

我有一个与 Retrofit2、liveData 和 Coroutines 一起使用的应用程序，用于通过我的 API 获取信息。我需要取消工作，如果我们开始新的工作，我尝试使用 Job.cancel()，但出现了问题。

这是我的视图模型：

class MembersViewModel(private val memberRepository: MemberRepository) : ViewModel() {

    private var job = Job()

    fun getMembers(category: String, year: String) = liveData(job + Dispatchers.IO) {

        emit(Resource.loading(null))

        try {
            val data = memberRepository.getMembers(category, year)
            if (year == "2008") delay(6000)
            if (data.isSuccessful) emit(Resource.success(data)) else emit(Resource.serverError(data))

        } catch (exception: Exception) {
            emit(Resource.error(null, exception.message ?: "Error occurred."))
        }
    }

    fun cancelJob() {
        job.cancel()
    }
}

片段，我称之为 ViewModel：

override fun onCreateView(
            inflater: LayoutInflater,
            container: ViewGroup?,
            savedInstanceState: Bundle?
    ): View {

        setViewModel()
        
        //some code

        binding.membersChipGroup.setOnCheckedChangeListener { chipGroup, chipId ->
            
            //some code

            setObservers(binding, year)
        }

        return binding.root
    }

private fun setViewModel() {
        viewModel = ViewModelProvider(this, ViewModelFactory(ApiHelper(RetrofitBuilder.apiService))).get(MembersViewModel::class.java)
}

private fun setObservers(binding: FragmentOfMembersViewPagerBinding, year: String) {

        viewModel?.cancelJob()

        viewModel?.getMembers(raceType, year)?.observe(viewLifecycleOwner, Observer { resource ->
            when (resource.status) {
                Resource.Status.SUCCESS -> {
                    resource.data?.let { members ->
                        binding.mtv1.text = members.body()?.last().toString()
                    }
                    
                }
                Resource.Status.ERROR -> {
                    //some code
                }
                Resource.Status.LOADING -> {
                    //some code
                }
                Resource.Status.SERVER_ERROR -> {
                    //some code
                }
            }
        })
}

如果我打电话viewModel?.cancelJob()，那么viewModel?.getMembers(raceType, year)不起作用，但如果我删除线路viewModel?.cancelJob()一切正常，但我无法取消viewModel?.getMembers(raceType, year)。

标签： androidkotlinretrofit2viewmodelkotlin-coroutines

解决方案

原因是您Job在使用它之前就取消了第一个，Coroutine Jobs一旦变为非活动状态，就不应使用它，否则它将不起作用。要在取消现有Jobin后实现这一点ViewModel，只需创建一个新的instance并分配它，它将按预期工作

视图模型

fun cancelJob() {
    job.cancel() //instance marked as stale, once cancelled
    job = Job() //new instance will work
}

推荐阅读