Awesome GitHub RepositoriesFunctional Stream Transformations

RxSwift is a reactive programming library for Swift that provides a framework for managing push-based data flows and composing asynchronous, event-based programs. It utilizes observable sequences and functional operators to transform and filter asynchronous sequences through a declarative approach. The library is distinguished by its ability to link asynchronous data streams directly to user interface elements, automating view updates via reactive data binding. It includes specialized tools for tracking UI control properties and events on the main thread, as well as the ability to encapsulate

ReactiveCocoa is a functional reactive programming framework and Cocoa UI binding layer. It provides a library for composing asynchronous data streams and managing application state through signals and functional operators. The framework functions as an Objective-C data binding library that links object properties and method calls to reactive streams using runtime dynamism and swizzling. It includes a utility to convert traditional key-value observation notifications into composable streams for synchronized state tracking. The project covers reactive UI programming by connecting interface el

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.

RxPY es una librería de programación reactiva funcional y una librería de observables ReactiveX para Python. Funciona como un procesador de flujos asíncronos y un framework de coordinación basado en eventos, utilizado para construir pipelines de datos que reaccionan a cambios de estado o flujos de eventos a lo largo del tiempo. La librería proporciona un kit de herramientas para componer programas asíncronos y basados en eventos mediante secuencias observables y operadores. Se distingue por el uso de planificadores (schedulers) configurables para gestionar la concurrencia, el timing y los ciclos de vida de las suscripciones. El proyecto cubre una amplia gama de capacidades de procesamiento de flujos, incluyendo agregación, filtrado y combinación de datos. Proporciona mecanismos para la difusión de eventos, almacenamiento en búfer de secuencias y gestión de errores, así como herramientas para coordinar flujos observables con bucles de eventos asíncronos. Las pruebas y el aseguramiento de la calidad se apoyan en la simulación de tiempo virtual, el modelado con diagramas de mármol y la verificación de emisiones.

Streem es un lenguaje de programación basado en flujos y orquestador de pipelines de datos. Proporciona un lenguaje específico de dominio para definir flujos de datos concurrentes, permitiendo a los usuarios vincular fuentes de datos a destinos a través de una secuencia de operaciones que transforman y filtran elementos de flujo individuales. El sistema utiliza una sintaxis de script personalizada para definir conexiones de flujo de datos y definiciones de pipeline. Esto permite la orquestación del procesamiento de datos concurrente donde múltiples etapas del pipeline se ejecutan simultáneamente para mover elementos de datos a través del sistema. La plataforma cubre la transformación funcional de datos y la composición basada en etapas, aplicando funciones específicas para modificar o filtrar elementos a medida que pasan a través de una cadena secuencial de operaciones vinculadas.

Bond es un framework de enlace de datos para Swift diseñado para sincronizar modelos de datos y elementos de interfaz de usuario a través de flujos de valores unidireccionales y bidireccionales. Funciona como una suite reactiva para monitorear cambios en colecciones, transformar flujos de datos y conectar eventos de interfaz de usuario con modelos de datos. El proyecto proporciona un puente reactivo que transforma las interacciones de la interfaz de usuario y las llamadas a métodos de delegados de protocolo en señales observables. Incluye un observador de colecciones para monitorear cambios en arrays y un procesador de flujo de datos funcional que aplica operadores para modificar o combinar valores antes de que lleguen a un elemento de interfaz de destino. El framework cubre amplias áreas de capacidad, incluyendo la sincronización a nivel de propiedad, enlace automatizado de fuentes de datos para vistas de tabla y colección, y la conversión de invocaciones de métodos de delegados en eventos de señal asíncronos.

RxDocs is a community-driven project that provides comprehensive technical documentation and educational resources for reactive programming. It serves as a centralized reference for developers implementing asynchronous data streams, offering detailed guides and operator specifications to support the management of complex event sequences. The project distinguishes itself by providing localized Chinese translations of technical concepts, ensuring that developers can access accurate information in their preferred language. It also focuses on accessibility by packaging these materials into portab