Awesome GitHub RepositoriesStream Aggregation

RxKotlin is a reactive programming library and asynchronous stream processor that provides Kotlin language extensions for composing event-based data streams. It serves as a set of Kotlin bindings for RxJava, allowing developers to transform, filter, and flatten sequences of data emitted over time. The library focuses on integrating RxJava patterns into Kotlin projects by applying language-specific conventions and idioms. It utilizes extension functions to simplify reactive programming patterns, reduce boilerplate, and optimize workflows within the reactive ecosystem. The toolkit covers a bro

Reactor Core ist ein Toolkit für reaktive Programmierung und eine nicht-blockierende Grundlage für die Komposition asynchroner Datenpipelines auf der JVM. Es dient als Framework für asynchrone Stream-Verarbeitung und als Backpressure-Managementsystem, das es Entwicklern ermöglicht, Ereignissequenzen zu transformieren, zu filtern und zu kombinieren, während der Datenfluss zwischen Produzenten und Konsumenten reguliert wird, um Ressourcenerschöpfung zu vermeiden. Die Bibliothek differenziert sich durch ein ausgeklügeltes Concurrency-Scheduling-System und nachfragebasierte Flusskontrolle. Sie entkoppelt die Signalverarbeitung von spezifischen Threads unter Verwendung einer Scheduler-Registry und bietet Mechanismen für die kontextbewusste Propagierung unveränderlicher Metadaten über asynchrone Grenzen hinweg. Sie enthält zudem spezialisierte Tools für die Trace-Erfassung zur Assembly-Zeit und Virtual-Time-Scheduling, um das Testen zeitbasierter Operatoren zu erleichtern. Das Projekt deckt ein breites Spektrum an Funktionen ab, einschließlich funktionaler Datenverarbeitung für Sequenzaggregation und Windowing, einer Vielzahl von Fehlerbehebungsstrategien wie exponentiellem Backoff-Retry sowie Dienstprogrammen zur Überbrückung von Legacy-Callback- oder synchronen APIs in reaktive Streams. Zudem bietet es Instrumentierung für Pipeline-Monitoring und eine Suite von Test-Tools zur Verifizierung von Signalsequenzen.

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