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 JVM पर एसिंक्रोनस डेटा पाइपलाइनों को कंपोज़ करने के लिए एक रिएक्टिव प्रोग्रामिंग टूलकिट और नॉन-ब्लॉकिंग आधार है। यह एक एसिंक्रोनस स्ट्रीम प्रोसेसिंग फ्रेमवर्क और बैकप्रेशर प्रबंधन प्रणाली के रूप में कार्य करता है, जो डेवलपर्स को इवेंट्स के अनुक्रमों को बदलने, फ़िल्टर करने और संयोजित करने की अनुमति देता है, जबकि संसाधन थकावट को रोकने के लिए उत्पादकों और उपभोक्ताओं के बीच डेटा प्रवाह को नियंत्रित करता है। लाइब्रेरी एक परिष्कृत समवर्ती शेड्यूलिंग प्रणाली और मांग-आधारित प्रवाह नियंत्रण के माध्यम से खुद को अलग करती है। यह एक शेड्यूलर रजिस्ट्री का उपयोग करके विशिष्ट थ्रेड्स से सिग्नल प्रोसेसिंग को अलग करती है और एसिंक्रोनस सीमाओं के पार अपरिवर्तनीय मेटाडेटा के संदर्भ-जागरूक प्रसार के लिए तंत्र प्रदान करती है। इसमें असेंबली-टाइम ट्रेस कैप्चर और समय-आधारित ऑपरेटरों के परीक्षण को सुविधाजनक बनाने के लिए वर्चुअल-टाइम शेड्यूलिंग के लिए विशेष उपकरण भी शामिल हैं। यह प्रोजेक्ट अनुक्रम एकत्रीकरण और विंडोइंग के लिए कार्यात्मक डेटा प्रोसेसिंग, घातीय बैकऑफ़ रिट्रीज़ जैसी विभिन्न त्रुटि पुनर्प्राप्ति रणनीतियों और रिएक्टिव स्ट्रीम में लीगेसी कॉलबैक या सिंक्रोनस API को ब्रिज करने के लिए उपयोगिताओं सहित क्षमताओं की एक विस्तृत श्रृंखला को कवर करता है। यह पाइपलाइन निगरानी के लिए इंस्ट्रूमेंटेशन और सिग्नल अनुक्रमों को सत्यापित करने के लिए परीक्षण उपकरणों का एक सूट भी प्रदान करता है।

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

This repository serves as an educational resource for implementing asynchronous programming patterns in Android applications using Kotlin Coroutines and Flow. It provides a collection of practical examples and unit tests designed to demonstrate how to manage background tasks, concurrent network requests, and reactive data streams while maintaining a responsive user interface. The project focuses on structured concurrency, offering patterns for organizing tasks into hierarchical scopes that automatically propagate cancellation and lifecycle signals. It emphasizes the integration of lifecycle-a