Tag: rx java

RXJava – buffer observable 1 hasta que se pueda observar 2 emite un elemento

Quiero el siguiente comportamiento: observableMain debe almacenar todos los ítems hasta que observableResumed emite un valor. A continuación, observableMain debe emitir todos los valores almacenados en buffer y todos los … Lo que hago en la activity's mi activity's : PublishSubject<T> subject = …; // I create a subject to emit items to and to […]

RxJava – cómo invocar abonado en eventos de 4 clics en Android

En android tengo una vista de texto definida de la siguiente manera: <TextView android:id="@+id/text1" android:layout_width="wrap_content" android:layout_height="wrap_content" android:text="@string/hello_world" android:textColorHighlight="#000000" android:textIsSelectable="true" /> Mi objetivo es que después de que se haga clic en 4 veces, quiero iniciar una nueva actividad. Necesito hacer esto con RXJava; Esto es un requisito. O bien rxAndroid , rxBinding , etc. Mi […]

¿Cuál es la manera correcta de burlarse de un RxJava Observable

Tengo una API que devuelve Observable 's para ser utilizado con RxJava. Para las pruebas, quiero evitar las operaciones de red, así que planea burlar las respuestas. Sin embargo, como todas las respuestas me deben envuelto con Observable y el método from() espera un Future no un tipo concreto, mi clase de burla es convoluted […]

RxJava subscribeOn y observeOn no anula el conjunto de Scheduler original antes?

Utilicé RxJava en android con Retrofit 2 y he invocado subscribeOn (Schedulers.io ()) android observeOn (AndroidSchedulers.mainThread ()) global antes de subscribe (). Sin embargo, alguna vez me gustaría llamar a subscribeOn (Schedulers.immediate ()) android observeOn (Schedulers.immediate ()) para anular los Schedulers establecidos antes para obtener el proceso sincronizado. Pero me pareció que no funciona, las […]

RxJava + Retrofit + sondeo

Tengo una llamada de Retrofit y quiero recordarla cada 30sec. Para ello, utilizo un Observable.interval(0, 30, TimeUnit.SECONDS) Observable .interval(0, 30, TimeUnit.SECONDS) .flatMap(x -> RestApi.instance().getUsers()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(list -> { // … }, error -> Timber.e(error, "can't load users")); Mi problema: Si falla la llamada de api, onError es llamado y la suscripción se cancela y la […]

Cómo recibir la última emisión de secuencia al llamar a rx.Observable.sample ()?

Estoy leyendo un archivo desde una URL remota y usando RxJava para informar sobre el progreso de la descarga. El registrador de archivos Observable emite una secuencia de objetos DownloadProgress. Debido a que se están emitiendo muchos elementos, estoy usando Observable.sample () para controlar la contrapresión. Esto funciona muy bien – actualizaciones de interfaz de […]

RxJava como bus de eventos en proyecto Android – eliminar evento del bus

Solía ​​trabajar con EventBus antes, que era fácil de usar y fácil de entender. Esta vez, sin embargo, me gustaría probar RxJava para la comunicación de bus de eventos, pero no está muy claro cómo eliminar eventos de RxJava o, mejor dicho, cómo debería ser diseñado correctamente para tener un comportamiento similar como EventBus ha […]

RxJava / RxAndroid – maneja varios cambios de EditText

Tengo 3 campos de EditText y he creado 3 observables para estos campos. Observable<CharSequence> o1 = RxTextView.textChanges(field1); Observable<CharSequence> o2 = RxTextView.textChanges(field2); Observable<CharSequence> o3 = RxTextView.textChanges(field3); Quiero habilitar un botón cuando todos estos tres campos tienen algún valor en él. El usuario puede introducir valores en cualquier orden en los campos. ¿Cómo puedo hacer eso? EDITAR […]

Flatten Observable <Observable <Cursor >> Observable <Cursor>

Tengo un Observable que devuelve una única instancia de Cursor ( Observable<Cursor> ). Estoy intentando utilizar ContentObservable.fromCursor para obtener la fila de cada cursor en la onNext llamada onNext . Una de las soluciones que he descubierto es tal construcción: ContentObservable.fromCursor(cursorObservable.toBlocking().first()) .subscribe(cursor -> { // map to object // add to outer collection }, e […]

Cancelar la suscripción de un rx.Single en RxJava

Hay varias situaciones en mi base de código donde una corriente que estoy suscribiendo a solamente emitirán solamente un resultado y como tal tiene sentido utilizar rx.Single vez de rx.Observable . La documentación de Single dice lo siguiente: Un Single llamará sólo uno de estos métodos, y sólo lo llamará una vez. Al llamar a […]