Resultados de la búsqueda a petición "rx-java2"
¿Cómo suscribir varios suscriptores a Observable o Flowable?
En el ejemplo de Hello World hay un suscriptor public static void main(String[] args) { Flowable.just("Hello world").subscribe(System.out::println); }¿Cómo hacer dos o más?
Sujeto RxJava con contrapresión: solo deje que el último valor se emita una vez que el flujo descendente haya terminado de consumir
Tengo un PublishSubject que llamaonNext() en algún evento de IU. El suscriptor generalmente tarda 2 segundos en completar su trabajo. Necesito ignorar todas las llamadas aonNext() excepto el último mientras el suscriptor está ocupado. Intenté lo ...
Ejecute el método vacío en segundo plano
Quiero ejecutar un método en segundo plano usando rxjava. No me importa el resultado. void myHeavyMethod() { (...) }Hasta ahora, la única solución que tengo es modificar el tipo de retorno a, p.boolean. boolean myHeavyMethod() { (...) return ...
¿Suscribirse con Vs suscribirse en RxJava2 (Android)?
¿Cuándo llamar al método subscribeWith en lugar de simple suscribirse? ¿Y cuál es el caso de uso? compositeDisposable.add(get() .observeOn(AndroidSchedulers.mainThread()) .subscribeOn(Schedulers.io()) ...
¿Cuál es la forma correcta de darse de baja de Single?
Quiero hacer algo después de un breve retraso: public void notifyMe() { Single .timer(500, TimeUnit.MILLISECONDS) .subscribeOn(Schedulers.io()) .subscribe(ignore -> service.notifyMe())); }Ahora tengo una advertencia:"The result of subscribe is ...
RxJava buffer hasta cambiado
Tengo un observable que emite una gran cantidad de datos como [1,1,1,2,2,2,3,3,1,1,5,5 ......] En RxJava podemos usardistinctUntilChanged () [http://reactivex.io/documentation/operators/distinct.html]para obtener elementos distintos hasta que ...
Flowable concatMapSingle sin captación previa para ignorar los clics hasta que finalice el procesamiento
Quiero manejar los clics de tal manera que se ignoren siempre que esté procesando algún clic que se haya producido. Pensé que podría hacerlo utilizando la contrapresión, como esta: private val clicks = PublishProcessor.create<Unit>() // ... ...
Usando RxJava 2 y Retrofit 2, problema de versión del adaptador
He agregado un nuevo módulo de biblioteca al módulo de aplicación existente en Android Studio. La principal diferencia fue agregar RxJava 2 y Retrofit 2. Después de actualizar build.gradle del nuevo módulo, comencé a recibir el siguiente ...
Observable.combineLa última inferencia de tipos en kotlin
Estoy usando RxJava2, Kotlin-1.1 junto con RxBindings en mi proyecto. Tengo una pantalla de inicio de sesión simple con el botón 'iniciar sesión' deshabilitado de forma predeterminada, quiero habilitar el botón solo cuando los campos de edición ...
¿Cuál es la diferencia entre Observable, Completable y Single en RxJava?
¿Alguien puede explicar la diferencia entre Observable, Completable y Single en RxJava con ejemplos claros? ¿En qué escenario usamos uno sobre los otros?