Tag: rx java

Cancelación de varias suscripciones a la vez en RxAndroid – Android

Yo uso Retrofit con RxAndroid para manejar un par de solicitudes en una actividad, Así que tengo variables de suscripción pareja en la actividad como público, public Subscription sub1; public Subscription sub2; public Subscription sub3; public Subscription sub4; public Subscription sub5; ahora en el onStop de la actividad quiero cancelarlos todos (si no terminaron). ¿Hay […]

Repetir la llamada API con retrofit y rxjava

Tengo un retrofit observable: @GET("something/") Observable<Something> getSomething(); la suscripción a ella da la respuesta. getSomething().subscribe(new Subscriber<Something>() { @Override public void onCompleted() { } @Override public void onError(Throwable e) { } @Override public void onNext(Something something) { //update database of something } }); ¿cómo puedo hacer esta llamada cada 60 segundos para que pueda actualizar la […]

Escritura de pruebas síncronas para Rx v2 Flowable

Estoy convirtiendo mi proyecto de Rx v1 a Rx v2, y estoy actualmente en el proceso de cambio de algunos de los v1 Observable s a v2 Flowable s. (Su en el proyecto de Android con unittests escrito en Groovy con Spock) Normalmente sólo anularía los Schedulers usando un gancho. Todavía puedo hacer esto en […]

RxAndroid filter Observable <List <Item >>

Utilizo RxAndroid y me gustaría filtrar el resultado de un Observable<List<Item>> . Aquí está el código: Observable<List<Item>> observable = Observable.create((Observable.OnSubscribe<List<Item>>) subscriber -> { subscriber.onNext(ItemManager.getItems()); subscriber.onCompleted(); }); Me gustaría usar .filter() para obtener sólo los elementos válidos. Hacer esto sería perfecto: observable.filter(new Func1<Item, Boolean>() { @Override public Boolean call(Item item) { return item.isValid(); } }); Sin […]

¿Debo cancelar la suscripción al utilizar rxbinding?

Hay cómo uso RxBinding con Kotlin: override fun onViewCreated(view: View?, savedInstanceState: Bundle?) { super.onViewCreated(view, savedInstanceState) reset_password_text_view.clicks().subscribe { presenter.showConfirmSecretQuestionBeforeResetPassword() } password_edit_text.textChanges().skip(1).subscribe { presenter.onPasswordChanged(it.toString()) } password_edit_text.editorActionEvents().subscribe { presenter.done(password_edit_text.text.toString()) } } Observable.subscribe(action) devuelve la Subscription . ¿Debo mantenerlo como referencia y onPause() suscripción onPause() o onDestroy() ? Me gusta esto: private lateinit var resetPasswordClicksSubs: Subscription override fun onViewCreated(view: […]

¿Cómo terminar un observable?

Tengo un Observable que quiero terminar si una cierta condición no se cumple (es decir, si la respuesta de un sitio web determinado no tiene éxito), para que pueda volver a consultar el sitio web, y llamar a los observables de nuevo. ¿Cómo hago para hacerlo? Esto es lo que quiero hacer: Observable.create(new Observable.OnSubscribe<String>() { […]

Actualización de datos mediante SQLBrite + Retrofit

Aquí está mi caso de uso: Estoy desarrollando una aplicación que se comunica con un servidor a través de una API REST y almacena los datos recibidos en una base de datos SQLite (se utiliza como un caché de algunos tipos). Cuando el usuario abre una pantalla, debe ocurrir lo siguiente: Los datos se cargan […]

¿Tenemos alguna posibilidad de detener la solicitud en OkHttp Interceptor?

En nuestra aplicación nos reunimos con un caso especial – si nuestro App.specialFlag == true , necesitamos detener cualquier solicitud de nuestro código. Y pensamos, que el mejor enfoque en esta situación es incluir el Interceptor especial que detendrá nuestras peticiones, algo así: if (App.specialFlag) { // Somehow stop request } else { return chain.proceed(chain.request()); […]

Inter fragmento de comunicación utilizando rxjava

Tengo una actividad con un fragmento. Dentro de ese fragmento hay un viewpager y dentro hay una lista. Ahora, una vez que el usuario hace clic en un elemento de la lista el fragmento debe ser reemplazado por otro fragmento y necesito pasar algunos datos como la posición de la lista y algunos otros valores […]

Realm + Retrofit + Rxjava

Estoy tratando de encontrar una manera de salvar a mi Parsed objetos de retro en el reino a través de rxjava observable. Ahora mismo tengo una llamada a la API: fetchCatalogData().subscribeOn(Schedulers.io()) .subscribe(data -> saveToRealm(); ) Esto no funciona porque yo estoy usando el reino en diferentes bandas o que scheduler.io no tiene un looper. No […]