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 este un toolkit de programare reactivă și o fundație non-blocking pentru compunerea pipeline-urilor de date asincrone pe JVM. Servește drept framework de procesare a fluxurilor asincrone și sistem de gestionare a backpressure-ului, permițând dezvoltatorilor să transforme, filtreze și combine secvențe de evenimente în timp ce reglează fluxul de date între producători și consumatori pentru a preveni epuizarea resurselor. Biblioteca se diferențiază printr-un sistem sofisticat de programare a concurenței și control al fluxului bazat pe cerere. Decuplează procesarea semnalelor de firele de execuție specifice folosind un registru de scheduler și oferă mecanisme pentru propagarea metadatelor imutabile conștiente de context peste limitele asincrone. De asemenea, dispune de instrumente specializate pentru capturarea urmelor la momentul asamblării și programarea timpului virtual pentru a facilita testarea operatorilor bazați pe timp. Proiectul acoperă o gamă largă de capabilități, inclusiv procesarea funcțională a datelor pentru agregarea și windowing-ul secvențelor, o varietate de strategii de recuperare a erorilor precum reîncercările cu backoff exponențial și utilitare pentru a conecta API-urile legacy de tip callback sau sincrone în fluxuri reactive. Oferă, de asemenea, instrumente pentru monitorizarea pipeline-ului și o suită de instrumente de testare pentru verificarea secvențelor de semnale.

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

Acest repository servește drept resursă educațională pentru implementarea modelelor de programare asincronă în aplicațiile Android folosind Kotlin Coroutines și Flow. Oferă o colecție de exemple practice și teste unitare concepute pentru a demonstra cum să gestionezi sarcinile de fundal, cererile de rețea concurente și fluxurile de date reactive, menținând în același timp o interfață utilizator responsivă. Proiectul se concentrează pe concurența structurată, oferind modele pentru organizarea sarcinilor în scope-uri ierarhice care propagă automat semnalele de anulare și ciclul de viață. Pune accent pe integrarea networking-ului conștient de ciclul de viață, asigurându-se că operațiunile de fundal și fluxurile reactive respectă starea componentelor Android pentru a preveni memory leak-urile și crash-urile. Implementarea acoperă o gamă largă de capabilități pentru construirea de sisteme de date reziliente, inclusiv utilizarea operatorilor funcționali pentru a transforma secvențele de date și conversia fluxurilor reci (cold streams) în containere de stare fierbinți (hot state containers). De asemenea, demonstrează strategii pentru gestionarea operațiunilor de rețea, cum ar fi implementarea reîncercărilor cu backoff exponențial, gestionarea timeout-urilor cererilor și utilizarea stocării locale pentru accesul la date offline-first. Repository-ul include modele de testare specializate pentru a verifica corectitudinea logicii multi-threaded și a comportamentului asincron.