Tag: observable

Observable OnCompleted no puede actualizar la interfaz de usuario

Estoy tratando de Toast terminar una llamada de servicio. Sin embargo, en el método onComplete recibo esta excepción: java.lang.RuntimeException: No se puede crear el controlador dentro de hilo que no ha llamado Looper.prepare () Se tira de SafeSubscriber#onNext(T args) que se ve así: /** * Provides the Subscriber with a new item to observe. * […]

Solución global de errorHandling con RxJava sólo cuando onError no está implementado

Tengo un error general que maneja la solución en mi app que se debe invocar siempre que onError se llama. En lugar de implementar onError para cada subscribe lo he hecho dentro de la clase Application : RxJavaPlugins.getInstance().registerErrorHandler(new RxJavaErrorHandler() { @Override public void handleError(final Throwable throwable) { new ErrorHandler().call(throwable); } }); Sin embargo, me gustaría […]

¿Es una práctica aceptable usar Objetos Singleton para guardar el estado o compartir datos entre Actividades?

Sería bueno si StackOverflow tuviera una sección en la que podríamos publicar tutoriales como el mío para que pueda responder literalmente cientos de preguntas que se han hecho aquí con un solo golpe. Vea … todos los días leo preguntas sobre cómo pasar objetos complejos entre actividades, cómo guardar el estado para que la aplicación […]

RxJava + retrofit, obtenga una lista y agregue información adicional para cada artículo

Estoy jugando con RXJava, retrofit en Android. Estoy tratando de lograr lo siguiente: Necesito hacer una encuesta periódicamente una llamada que me da un Observable> (Desde aquí podría hacerlo) Una vez que consiga esta lista quiero iterar en cada entrega y llamar a otros métodos que me dará la ETA (tan sólo más información) Quiero […]

¿Cómo implemento un observador para obtener datos de un oyente?

Estoy usando la biblioteca MaterialDrawer para crear un cajón simple para mi aplicación, algunas de las instancias de las clases en la biblioteca necesitan una cadena pasada a ellos cuando se llama. Un ejemplo es la clase IProfile : IProfile profile = new ProfileDrawerItem().withName("John Doe"); Donde el método withName() toma una cadena. He creado una […]

¿Cómo crear un observable de Hashmap?

Basado en la documentación de ReactiveX El operador del operador puede convertir un Futuro, un Iterable o un Array. En el caso de un Iterable o un Array, el Observable resultante emitirá cada elemento contenido en el Iterable o Array. Podemos tener un observable de una Array o List y observable emite los elementos de […]

Observable vs. Servicio en Android

Quiero migrar de medios de API de Android de ejecución asincrónica a Rx. Particularmente tengo una galería de fotos en mi aplicación que frecuentemente obtiene nuevas fotos de un servidor a medida que el usuario pincha las fotos (se basa en ViewPager con desplazamiento lateral). Sucedió así: cada vez que ViewPager quería una nueva foto, […]

Limitar el rendimiento con RxJava

El caso en el que estoy ahora es bastante difícil de explicar, por lo que escribiré una versión más sencilla para explicar el problema. Tengo un Observable.from() que emite una secuencia de archivos definidos por un ArrayList de archivos. Todos estos archivos deben cargarse en un servidor. Para eso tengo una función que hace el […]

¿Cómo ejecutar 2 consultas secuencialmente en un Android RxJava Observable?

Quiero ejecutar 2 tareas asíncronas, una seguida por la otra (secuencialmente). He leído algo sobre ZIP o Flat, pero no lo entendí muy bien … Mi propósito es cargar los datos de un SQLite local, y cuando termina, llama a la consulta al servidor (remoto). ¿Puede alguien sugerirme, una manera de lograr eso? Este es […]

¿Cómo se pueden manejar múltiples solicitudes para llenar modelos con RXJava Observables?

Estamos utilizando ReactiveX y Retrofit en nuestra pila de red para manejar todas las solicitudes de API de forma asíncrona. Nuestro objetivo es crear un método que devuelva una colección completamente poblada de modelos de User . Cada modelo de User tiene una lista de objetos Pet . Podemos obtener todos los modelos de User […]