RxJava, wykonaj kod w wątku obserwatora przed powiązaniem dwóch obserwowalnych

Question

Używam RxJava i RxAndroid, i chcę połączyć dwa obserwowalne, ale w międzyczasie muszę zaktualizować interfejs, więc muszę wykonać kod w głównym wątku przed docierając do subskrybenta.

Jednym z rozwiązań, zamiast płaskiego mapowania (czy jest to akceptowany termin?) Dwóch obserwatorów, byłoby wywołanie następnego obserwowalnego w subskrybencie zaraz po aktualizacji interfejsu użytkownika, ale uważam, że powinno być bardziej eleganckie rozwiązanie takie jak:

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

Oczywiście, prawdopodobnie mapa nie jest operatorem, którego potrzebuję tutaj użyć. Czy istnieje operator lub lepszy sposób na osiągnięcie tego celu? Czy też brakuje mi punktu widzenia tego, jak działają obserwowalne?

Answer 1

Rxjava ma operator doOnnext, którego właśnie szukasz.