Preguntas con etiqueta "rx-java"

1

Android - observación de la DB cambios dentro de ViewModel

Estoy usando un montón de LiveData en mis proyectos y es ideal en aquellos casos en que necesito para pasar algo de vistas, ya que la intención es ser observados por el ciclo de vida de los propietarios (es decir, puntos de vista). Pero me pregunto...
1

Cómo Observable es creado en retrofit sin llamarlo de programador?

Estoy trabajando en rx-java y de readaptación, y tengo algunas consultas relacionadas con ella.Yo no soy capaz de entender que cuando llamamos a continuación el código, a continuación, cómo Observable(Observable) es creada ? De acuerdo, a mi entender...
0

Retrofit OutOfMemory excepción durante la carga de archivos en BASE64 para servidor

Tuve una OOM excepción cuando intentó cargar un archivo pdf en base64 como un campo en un modelo de tirar de Reconversión. Yo sé, que esto no es una forma normal para subir archivos, pero no a un tercero la realización. Cómo puedo solucionar este tip...
0

Cómo hacer el tiempo de espera de operador de fuego excepción de una vez en RxJava2 (RxJava3) de la cadena antes de reintentar

Yo estoy tratando de extender la funcionalidad de mi personalizados FlowableTransformer que yo uso para condicionalmente cambiar de un Flowable a otro, devuelto por siempre Function<T, Flowable<R>>, es decir, en mi switchFunction I enviar...
0

Rxjava grandes no. de la Iteración, a continuación, omita los registros

Estoy atascado en un proceso en mi proyecto actual. Yo no puedo hablar mucho sobre el proyecto, es por eso Que estoy explicando la parte donde me quedé atrapado. Hay una gran cantidad de registros en el proyecto, digamos que 2 Millones y quiero reco...
0

Filtro con componer operador en RxJava

Tengo una clase que herede de FlowableTransformer, Estoy tratando de tener una PublishSubject o PublishProcessor a triger de un Observable con este componer : val transformerClass = TestTranformer() val testTriger = PublishProcessor...
2

HiveMQ excepción despedido después de que el modo avión, la Sesión expiró, tal y como se ha cerrado la conexión

He implementado HiveMQ dentro de un subproceso de fondo con éxito, pero hay un pequeño problema después de activar el modo avión. El registro muestra la razón, pero creo que hay algo que falta y no puedo ver de donde es la falta de controlador de err...
0

La App se bloquea cuando puedo solicitar una llamada desde el servidor

Siempre que hago una solicitud a la API, la aplicación se congela y solo con esta solicitud. Cuando se ejecuta en el cartero, toma 1407ms para la respuesta Traté de suscripción en diferentes Programadores, pero todavía se congela. este es mi códig...
1

RxJava2 Fluida para distinguir el último elemento

Quiero proceso de Flowable en lotes, y a la manija de la última hornada de manera diferente. Existe una mejor manera de utilizar un AtomicReference para almacenar en caché el lote anterior y el proceso de la última hornada en onComplete()? Ato...