rxjava cómo usar universal

RxJava es una implementación de código abierto de ReactiveX en Java. RxJava es un marco que facilita el manejo de tareas de subprocesos en segundo plano o de subprocesos de interfaz de usuario en diferentes entornos de ejecución. La implementación asincrónica de RxJava se implementa mediante el patrón de observador extendido.

Observable y Subscriber son las dos clases principales. En RxJava, un Observable es una clase que emite un flujo de datos o eventos, y un Suscriptor es una clase que procesa (ejecuta) estos elementos emitidos (flujos o eventos).

Observable y Observer implementan relaciones de suscripción a través del método subscribe(). La secuencia estándar de un Observable emite uno o más elementos, que luego se completan con éxito o con un error. Un Observable puede tener varios suscriptores y cada elemento emitido a través del Observable se enviará al método Subscriber.onNext() para su procesamiento. Una vez que el Observable ya no emite elementos, llamará al método Subscriber.onCompleted(), y si uno de los suscriptores comete un error, el Observable llamará al método Subscriber.onError().

onNext(): método de devolución de llamada de eventos RxJava para eventos normales.

onCompleted(): la cola de eventos se completa; RxJava no solo maneja cada evento individualmente, sino que también los trata como una cola. Cuando onNext() ya no se emite, RxJava necesita activar onCompleted(). método.

onError(): Excepción en la cola de eventos. Cuando ocurre una excepción durante el procesamiento de eventos, se activará onError() y la cola finalizará automáticamente sin enviar ningún evento.

En una secuencia de eventos que se ejecuta normalmente, onCompleted() y onError() son el único y el último en la secuencia de eventos. Tenga en cuenta que onCompleted() y onError() también son mutuamente excluyentes, es decir, si se llama a uno en la cola, no se debe llamar al otro.

Figura 1: modo observador de RxJava (extraído de "RxJava para desarrolladores de Android")

RxAndroid es una versión portada de RxJava agregada a la plataforma Android, también necesita; para presentar el paquete RxJava.