Resultados de la búsqueda a petición "rx-java"
Observable se ejecuta en el hilo principal, aunque se suscribe subscribeOn () en otro hilo
Tengo un problema extraño en una de mis actividades. Cuando regrese de tomar una foto / video, en mionActivityResult Estoy mostrando un cuadro de diálogo que permite al usuario nombrar la cámara. Una vez que el usuario presiona OK, envíoonNext() ...
Cuándo cancelar una suscripción
Tengo una pregunta sobre cómo cancelar la suscripción de un observable. Tengo dos códigos y no estoy seguro de cuál es mejor. Ejemplo 1 -> Darse de baja del suscriptor una vez que la transmisión haya finalizado: Subscriber<String> subscriber = ...
¿Cómo se puede pausar un Observable sin perder los elementos emitidos?
Yo tengo unObservable que emite tics cada segundo: Observable.interval(0, 1, TimeUnit.SECONDS) .take(durationInSeconds + 1));Me gustaría pausar este Observable para que deje de emitir números y reanudarlo a pedido. Hay algunas trampas: de ...
ReactiveX emite un valor nulo o centinela después del tiempo de espera
Buscando una manera limpia de transformar una fuenteObservable para emitir un solonull (o valor centinela) después de no emitir un elemento durante un tiempo. Por ejemplo, si la fuente observable emite1, 2, 3 luego deja de emitir por 10 segundos ...
RxJava: elementos del búfer hasta que se cumpla alguna condición para el elemento actual
Aquí hay un fragmento que estoy tratando de descifrar: class RaceCondition { Subject<Integer, Integer> subject = PublishSubject.create(); public void entryPoint(Integer data) { subject.onNext(data); } public void client() { subject /*some ...
Rx: ¿un operador tipo zip que continúa después de que una de las transmisiones finalizó?
Estoy buscando combinar secuencias (observables) que comienzan y terminan de forma asincrónica: -1----1----1----1---|-> -2----2--|-> [ optional_zip(sum) ] -1----3----3----1---|->Para qué lo necesito: Agregar secuencias de audio juntas. Son ...
Cómo manejar errores de red en Retrofit 2 con RxJava
Estoy usando Retrofit2 con RxJava. Entonces mi llamada se parece a algo subscriptions.add(authenticateUser(mReq, refreshRequest) .observeOn(Schedulers.io()) .subscribeOn(Schedulers.io()) .subscribe(authResponseModel -> { ...
Solo observable con múltiples suscriptores
Yo tengo unObservable<<List<Foo>> getFoo() que se crea desde un Servicio de actualización y después de llamar al.getFoo() método, necesito compartirlo con múltiples suscriptores. Llamando al.share() sin embargo, hace que la llamada de red se ...
RxJava: Cómo aplicar operadores condicionalmente a un observable sin romper la cadena
Tengo una cadena de operadores en un RxJava observable. Me gustaría poder aplicar uno de dos operadores dependiendo de un valor booleano sin "romper la cadena". Soy relativamente nuevo en Rx (Java) y siento que probablemente haya una forma más ...
¿Cómo usar Observable.fromCallable () con una excepción marcada?
Observable.fromCallable() es ideal para convertir una sola función en un Observable. Pero, ¿cómo maneja las excepciones marcadas que podría generar la función? La mayoría de los ejemplos que he visto usan lambdas y "simplemente funcionan". ¿Pero ...