rxjava

RxJava es una implementación de Java de las Extensiones Reactivas: una biblioteca para componer programas asíncronos y basados en eventos utilizando secuencias observables. Extiende el patrón observador para admitir secuencias de datos y eventos, añadiendo operadores que permiten a los desarrolladores componer secuencias de forma declarativa mientras abstraen preocupaciones de bajo nivel como el subprocesamiento, sincronización, seguridad de hilos y estructuras de datos concurrentes. El README documenta la versión 4.x, descrita como una implementación nativa de Java que no requiere bibliotecas de tiempo de ejecución de terceros, con soporte JPMS y OSGi, una implementación basada en java.util.concurrent.Flow, soporte de Virtual Thread, y un nuevo tipo Streamable construido alrededor del bloqueo virtual. También señala el uso del Reactive Streams Test Compatibility Kit, el uso de la API Cleaner de Java para la detección de fugas de recursos, y que el soporte de RxJava 3.x se reducirá después del lanzamiento de 4.x. Los conceptos básicos cubren agregar la dependencia (io.reactivex.rxjava4:rxjava) y un ejemplo Hola Mundo usando Flowable.just(...).subscribe(...). Los tipos base incluyen Flowable (0..N con retroceso), Observable (0..N sin retroceso), Single (exactamente un elemento o error), Completable (solo completado o error), Maybe (sin elemento, un elemento o error), y Streamable (bloqueo virtual con retroceso nativo). El README explica terminología como upstream/downstream, emisiones, retroceso, tiempo de montaje, tiempo de suscripción y tiempo de ejecución, con muestras de código para computación en segundo plano, schedulers, concurrencia dentro de un flujo, procesamiento paralelo, sub-flujos dependientes, continuaciones y conversiones de tipo entre tipos reactivos. También documenta convenciones de nomenclatura de operadores impulsadas por palabras clave de Java, erasure de tipo y ambigüedades de tipo.