android - RxJava，在链接两个可观察对象之前在观察者线程中执行代码

Question

我正在使用 RxJava 和 RxAndroid，我想结合两个可观察对象，但在两者之间我需要更新 UI，所以我必须在到达订阅者之前在主线程中执行代码。

一个解决方案，而不是平面映射(这是一个公认的术语吗？)两个可观察对象，是在更新用户界面后立即调用订阅者中的下一个可观察对象，但我觉得应该有一个更优雅的解决方案，如:

myObservable
    .map(new Func1<Object, Object>() {
        @Override
        public Object call(Object object) {
            /* do stuff on the main thread */
            return object;
        }
    })
    .flatMap(new Func1<Object, Observable<OtherObject>>() {
        @Override
        public Observable<OtherObject> call(Object o) {
            return new MyOtherObservable(o);
        }
    })
    .subscribeOn(Schedulers.newThread())
    .observeOn(AndroidSchedulers.mainThread());

当然，可能 map 不是我需要在这里使用的运算符。那么，是否有运营商或更好的方法来实现这一目标？还是我忽略了关于可观察对象应该如何工作的要点？

Answer 1

Rxjava 有一个 doOnNext 运算符，这正是您要找的。