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 is a reactive programming toolkit and non-blocking foundation for composing asynchronous data pipelines on the JVM. It serves as an asynchronous stream processing framework and a backpressure management system, allowing developers to transform, filter, and combine sequences of events while regulating data flow between producers and consumers to prevent resource exhaustion. The library differentiates itself through a sophisticated concurrency scheduling system and demand-based flow control. It decouples signal processing from specific threads using a scheduler registry and provide

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

该仓库作为教育资源，专注于使用 Kotlin Coroutines 和 Flow 在 Android 应用中实现异步编程模式。它提供了一系列实用的示例和单元测试，旨在演示如何在保持响应式用户界面的同时，管理后台任务、并发网络请求和响应式数据流。 该项目专注于结构化并发，提供了将任务组织成层级作用域的模式，这些作用域会自动传播取消和生命周期信号。它强调集成生命周期感知的网络功能，确保后台操作和响应式流尊重 Android 组件的状态，以防止内存泄漏和崩溃。 该实现涵盖了构建弹性数据系统的广泛能力，包括使用函数式操作符转换数据序列，以及将冷流转换为热状态容器。它还演示了处理网络操作的策略，例如实现带有指数退避的重试、管理请求超时以及利用本地存储进行离线优先的数据访问。该仓库包含专门的测试模式，用于验证多线程逻辑和异步行为的正确性。