Tag: rx java

Obtenga el valor actual de RxJava Observable

En mi UI tengo un RadioGroup con 3 RadioButtons y un Button "normal". Cuando el usuario hace clic en el Button Quiero leer el RadioButton seleccionado para hacer algo con él. RxView.clicks(button) .flatMap(x -> RxRadioGroup.checkedChanges(radioGroup_timer)) .map(view -> { switch (view) { case R.id.radioButton_10sec_timer: return 10; case R.id.radioButton_20sec_timer: return 20; default: return DEFAULT_TIMER; } }) .subscribe(duration […]

La llamada onNext de PublishSubject en un hilo diferente después de actualizar a Retrofit 2.0

Tengo una siguiente clase que mi compañero de trabajo creó mientras estábamos usando Retrofit 1.9 public class SomeApiCallAction { private Subscription subscription; private NoInternetConnectionInterface noInternetConnectionInterface; public interface NoInternetConnectionInterface { PublishSubject<Integer> noInternetConnection(Throwable throwable); } public void execute(Subscriber subscriber, NoInternetConnectionInterface noInternetConnectionInterface) { this.noInternetConnectionInterface = noInternetConnectionInterface; this.subscription = retrofit.someService().someApiCall() .subscribeOn(Schedulers.newThread()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(subscriber) .retryWhen(retryFunction); } public void cancel() { […]

¿Asignación de objetos cuando se usa RxJava en código de 'alto tráfico'?

Acabo de empezar a explorar RxJava recientemente y lo aplicó a una pequeña parte de mi proyecto. Resulta que esta parte es pequeña pero una con "alto tráfico": se llama mucho por otros componentes. Un ejemplo sería un cliente de red que se llama repetidamente para obtener datos remotos, aplica algunas transformaciones a la respuesta, […]

Suscribir 2 diferentes Observable y onNext ambos?

Dado que me suscribo a 2 diferentes Observables y quiero obtener ambos en onNext después de hacer algunas operaciones a ellos Digamos que tengo 2 Observables Observable<List<String>> childName = Observable.from(children)… some operations Observable<List<String>> teacherName = Observable.from(teachers)… some operations ¿Cómo consigo los dos en mi suscripción? subscribe( onNext(List<String> childName, List<String> className) De modo que pueda pasar […]

Problema relacionado con API observable y cancelación de suscripción

Estoy tratando de usar Rx-Java para crear una clase de seguimiento de ubicación en Android. Lo que todavía no puedo entender es cómo manejar el ciclo de vida de mi Observable correctamente. Lo que quiero tener es un Observable que inicia la localización de seguimiento cuando ocurre la primera suscripción y detiene el seguimiento de […]

Introducción a RxJava con sqlite

Estoy en el proceso de aprender RxJava y he ido a través de varios artículos y videos. Me sentí totalmente impresionante de lo que RxJava puede ofrecer, por lo que creo que actualmente el sentido de lo que Reactive Programming es todo. Este tutorial de Dan Lew me ayudó un poco a entender los conceptos […]

Excepción fatal lanzada en el subprograma Scheduler.Worker con Retrofit 2 y Rx

Este es el código que utilizo para hacer llamadas Http. No puedo reproducir el error, pero Bugsnag me dice que algunos usuarios están recibiendo este error: java.lang.IllegalStateException StrictMode.java public class ApiManager { public interface Callback<T> { void onError(Throwable e); void onSuccess(T result); } private ApiService _apiService; public ApiManager() { Retrofit retrofit = new Retrofit.Builder() .baseUrl(BuildConfig.BASE_URL) […]

Retrofit 2 + Rxjava error de manipulación

Así que ya recibir un token de la Json cuando el inicio de sesión se realiza sin problemas, y recibir el hash Pero cuando la respuesta del servidor es un error, no puedo obtener el mensaje de Json ({message: "Error: email incorrecto}" porque en el onError sólo obtenemos como argumento una Throwable y no una […]

RxJava como un bus de eventos, onNext se llama varias veces cuando sólo un mensaje de evento

Estoy implementando un bus de eventos (RxBus) con RxJava. RxBus.java public class RxBus { private static final String TAG = LogUtils.makeTag(RxBus.class); private static final RxBus INSTANCE = new RxBus(); private final Subject<Object, Object> mBusSubject = new SerializedSubject<>(PublishSubject.create()); public static RxBus getInstance() { return INSTANCE; } public <T> Subscription register(final Class<T> eventClass, Action1<T> onNext) { return […]

Observable.just () que devuelve Unidad en Kotlin

Tengo un pedazo de Observable que al final o bien devuelve un error y reintentos o simplemente devuelve onNext. No necesito nada en onNext, así que esto es sólo un Observable<Unit> . Ahora el problema es que al final de la cadena tengo que golpear esto enNext y no tengo nada más que el buen […]