RxJava, ejecuta código en el hilo del observador antes de encadenar dos observables

Estoy usando RxJava y RxAndroid, y quiero combinar dos observables, pero entre lo necesario para actualizar la interfaz de usuario, por lo que debe ejecutar código en el hilo principal antes de llegar al suscriptor.

Una solución, en lugar de flatmapping (¿es un término aceptado?) Dos observables, sería llamar a la siguiente observable en el suscriptor justo después de actualizar la interfaz de usuario, pero siento que debería haber una solución más elegante como:

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()); 

Por supuesto, probablemente el mapa no es el operador que necesito usar aquí. Por lo tanto, hay un operador o una mejor manera de lograr esto? ¿O estoy perdiendo el punto sobre cómo deben funcionar los observables?

FlipAndroid es un fan de Google para Android, Todo sobre Android Phones, Android Wear, Android Dev y Aplicaciones para Android Aplicaciones.