从Rx到协程的分页数据源

如何解决从Rx到协程的分页数据源

我想使用Coroutine进行分页功能，我已经在loadInitial()和loadAfter()中使用了协程。但是问题是如何将retry()，setRetry()和setRetry(Action { loadAfter(params,callback) })从Rx更改为Coroutine？

import androidx.lifecycle.MutableLiveData
import androidx.paging.PageKeyedDataSource
import io.reactivex.Completable
import io.reactivex.android.schedulers.AndroidSchedulers
import io.reactivex.disposables.CompositeDisposable
import io.reactivex.functions.Action
import io.reactivex.schedulers.Schedulers

class NewsDataSource(
    private val networkService: NetworkService,private val compositeDisposable: CompositeDisposable)
    : PageKeyedDataSource<Int,News>() {

    var state: MutableLiveData<State> = MutableLiveData()
    private var retryCompletable: Completable? = null


    private val job = Job()
    private val scope = CoroutineScope(IO + job)


    override fun loadInitial(params: LoadInitialParams<Int>,callback: LoadInitialCallback<Int,News>) {
        scope.launch {
            try {
                .....
            }catch (exception : Exception){
                .....
            }
        }
    }

    override fun loadAfter(params: LoadParams<Int>,callback: LoadCallback<Int,News>) {
        scope.launch {
            try {
                .....
            }catch (exception : Exception){
                .....
                setRetry(Action { loadAfter(params,callback) }) // How to change this function from Rx to Coroutine
            }
        }
    }

    override fun loadBefore(params: LoadParams<Int>,News>) {}

    fun retry() { // How to change this function from Rx to Coroutine
        if (retryCompletable != null) {
            compositeDisposable.add(retryCompletable!!
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe())
        }
    }

    private fun setRetry(action: Action?) { // How to change this function from Rx to Coroutine
        retryCompletable = if (action == null) null else Completable.fromAction(action)
    }

}