Awesome GitHub RepositoriesReactive Stream Processing

Rx.NET is a reactive programming framework and library for the .NET ecosystem used to compose asynchronous and event-based programs. It provides an observable data stream API that treats live sequences of information as collections, allowing developers to coordinate asynchronous event workflows using a declarative syntax. The project functions as an extension of language integrated query patterns to asynchronous streams. This allows for the filtering and transformation of asynchronous notifications and event sequences through the application of query operators. The framework covers asynchron

This is a non-blocking network client for Java applications that provides asynchronous HTTP request capabilities and bidirectional WebSocket connectivity. It leverages a Netty-based architecture to handle high volumes of network input and output. The library utilizes native transport abstractions such as Epoll, KQueue, and io_uring to reduce system latency. It supports HTTP/2 multiplexing to run multiple concurrent request-response streams over a single connection and provides automatic response body decompression for various formats. Core capabilities cover the management of complex network

Reactor Core es un kit de herramientas de programación reactiva y una base no bloqueante para componer pipelines de datos asíncronos en la JVM. Sirve como framework de procesamiento de flujos asíncronos y sistema de gestión de contrapresión (backpressure), permitiendo a los desarrolladores transformar, filtrar y combinar secuencias de eventos mientras regulan el flujo de datos entre productores y consumidores para evitar el agotamiento de recursos. La biblioteca se diferencia por un sofisticado sistema de planificación de concurrencia y control de flujo basado en la demanda. Desacopla el procesamiento de señales de hilos específicos utilizando un registro de planificadores y proporciona mecanismos para la propagación de metadatos inmutables conscientes del contexto a través de límites asíncronos. También cuenta con herramientas especializadas para la captura de trazas en tiempo de ensamblaje y planificación de tiempo virtual para facilitar la prueba de operadores basados en el tiempo. El proyecto cubre una amplia gama de capacidades, incluyendo procesamiento funcional de datos para agregación y ventanas de secuencias, una variedad de estrategias de recuperación de errores como reintentos con retroceso exponencial y utilidades para conectar API de callback heredadas o síncronas en flujos reactivos. Además, proporciona instrumentación para el monitoreo de pipelines y un conjunto de herramientas de prueba para verificar secuencias de señales.

Effector is a reactive state management library and data flow orchestrator designed for building complex, event-driven applications. It models application logic as a directed acyclic graph, where state updates and asynchronous side effects propagate automatically through declarative pipelines. By decoupling business logic from user interface layers, it allows developers to maintain state in independent containers that communicate via standard interfaces, ensuring the system remains framework-agnostic. The library distinguishes itself through its robust support for isolated execution scopes, w

ZIO is a functional effect system for the JVM that models asynchronous and concurrent programs as pure, composable values with typed error handling and dependency injection. Its core identity is built on fiber-based concurrency, where lightweight, non-blocking fibers execute millions of concurrent tasks with structured lifecycle management, and a dual-channel error model that separates expected business failures from unexpected system defects at compile time. The system provides effect-typed dependency injection through a layer-based dependency graph, pull-based reactive stream processing with

Este repositorio sirve como recurso educativo para implementar patrones de programación asíncrona en aplicaciones Android utilizando Kotlin Coroutines y Flow. Proporciona una colección de ejemplos prácticos y pruebas unitarias diseñadas para demostrar cómo gestionar tareas en segundo plano, solicitudes de red concurrentes y flujos de datos reactivos mientras se mantiene una interfaz de usuario responsiva. El proyecto se centra en la concurrencia estructurada, ofreciendo patrones para organizar tareas en ámbitos jerárquicos que propagan automáticamente las señales de cancelación y ciclo de vida. Enfatiza la integración de redes conscientes del ciclo de vida, asegurando que las operaciones en segundo plano y los flujos reactivos respeten el estado de los componentes de Android para evitar fugas de memoria y bloqueos. La implementación cubre una amplia gama de capacidades para construir sistemas de datos resilientes, incluyendo el uso de operadores funcionales para transformar secuencias de datos y la conversión de flujos fríos en contenedores de estado calientes. También demuestra estrategias para manejar operaciones de red, como la implementación de reintentos con retroceso exponencial, la gestión de tiempos de espera de solicitudes y la utilización de almacenamiento local para el acceso a datos offline-first. El repositorio incluye patrones de prueba especializados para verificar la corrección de la lógica multihilo y el comportamiento asíncrono.