android - RxJava 在主线程中运行部分平面图

Question

您好，我正在尝试实现一个将两个请求链接在一起的单一可观察对象。

在我发出的两个请求之间，我通知回调以使用请求一个的响应更新 UI，然后在 Schedulaers.io 线程中启动下一个请求。

我遇到的问题是它也尝试从 schedulars.io 线程更新 UI，结果导致 ui 线程中没有任何更新。

我在 Android 中的 RunOnUiThread 代码块上冷包装了回调，但想知道是否有更优雅的方式来实现它？

我检查了协程，它似乎只是处理将一段代码放在一个单独的线程中。

这是我当前的代码

override fun getHomeScreenInformation() {
    delegator.requestOne()
            .flatMap { responseOne->
                homeScreenCallBack.onResponseOneRecieved(responseOne)
                delegator.requestTwo()
            }
            .observeOn(AndroidSchedulers.mainThread())
            .subscribeOn(Schedulers.io())
            .subscribe(
                    {responseTwo-> homeScreenCallBack.onResponseTwoRecieved(responseTwo)},
                    {error -> homeScreenCallBack.onError()}
            )
}

Answer 1

根据需要多次应用 observeOn(AndroidSchedulers.mainThread()):

delegator.requestOne()
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread()) // <----------------------
        .flatMap { responseOne ->
            homeScreenCallBack.onResponseOneRecieved(responseOne)
            delegator.requestTwo()
            .subscribeOn(Schedulers.io())          // <----------------------
        }
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(
                {responseTwo-> homeScreenCallBack.onResponseTwoRecieved(responseTwo)},
                {error -> homeScreenCallBack.onError()}
        )