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

Question

我使用的是RxJava和RxAndroid，我想将两个可观察到的东西结合起来，但在这两个东西之间，我需要更新UI，所以在到达订阅服务器之前，我必须在主线程中执行代码。

一个解决方案，而不是flatmapping（这是一个被接受的术语吗？）两个可观察到的，将是在更新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操作符，这就是您要找的。