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:
- Suscribir un cajón de navegación a un Observable
- Cómo manejar el `IllegalArgumentException` en RxJava?
- RxJava Break Chain en Condicional
- Realm, RxJava, asObservable () y doOnUnsubscribe ()
- AbstractMethodError cuando se utiliza RxJavaCallAdapterFactory en Retrofit 2
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?
- AsyncTask en RxJava
- Cómo recibir la última emisión de secuencia al llamar a rx.Observable.sample ()?
- .debounce () de RxJava interfiriendo con los hilos de mis observables y manejo de errores
- ¿Cuál es la diferencia entre RxJava y Bolts?
- OnNext comience otro Observable
- Uso de Mockito con Retrofit 2.0
- Rx Java mergeDelayError no funciona como se esperaba
- Introducción a RxJava con sqlite
Rxjava tiene un operador doOnNext que es lo que estás buscando.
- FTPClient corrompe las imágenes mientras se sube al servidor ftp en android?
- Borrar datos de usuario o Borrar caché en Phonegap android