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. تعمل كإطار عمل لمعالجة التدفق غير المتزامن ونظام إدارة الضغط العكسي، مما يسمح للمطورين بتحويل وتصفية ودمج تسلسلات الأحداث مع تنظيم تدفق البيانات بين المنتجين والمستهلكين لمنع استنفاد الموارد. تتميز المكتبة بنظام جدولة تزامن متطور وتحكم في التدفق قائم على الطلب. تفصل معالجة الإشارات عن خيوط معينة باستخدام سجل جدولة وتوفر آليات لنشر البيانات الوصفية غير القابلة للتغيير المدركة للسياق عبر الحدود غير المتزامنة. كما تتميز بأدوات متخصصة لالتقاط التتبع في وقت التجميع وجدولة الوقت الافتراضي لتسهيل اختبار المشغلين القائمين على الوقت. يغطي المشروع مجموعة واسعة من القدرات، بما في ذلك معالجة البيانات الوظيفية لتجميع التسلسل والنافذة، ومجموعة متنوعة من استراتيجيات استرداد الأخطاء مثل إعادة المحاولة ذات التراجع الأسي، وأدوات لربط رد الاتصال القديم أو واجهات برمجة التطبيقات المتزامنة في تدفقات تفاعلية. كما يوفر أدوات لمراقبة خط الأنابيب ومجموعة من أدوات الاختبار للتحقق من تسلسلات الإشارة.

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

يعمل هذا المستودع كمورد تعليمي لتنفيذ أنماط البرمجة غير المتزامنة في تطبيقات Android باستخدام Kotlin Coroutines و Flow. يوفر مجموعة من الأمثلة العملية واختبارات الوحدات المصممة لتوضيح كيفية إدارة مهام الخلفية، وطلبات الشبكة المتزامنة، وتدفقات البيانات التفاعلية مع الحفاظ على واجهة مستخدم متجاوبة. يركز المشروع على التزامن المهيكل (structured concurrency)، حيث يقدم أنماطاً لتنظيم المهام في نطاقات هرمية تقوم تلقائياً بنشر إشارات الإلغاء ودورة الحياة. ويؤكد على تكامل الشبكات المدركة لدورة الحياة، مما يضمن أن عمليات الخلفية وتدفقات البيانات التفاعلية تحترم حالة مكونات Android لمنع تسرب الذاكرة والأعطال. يغطي التنفيذ نطاقاً واسعاً من القدرات لبناء أنظمة بيانات مرنة، بما في ذلك استخدام العوامل الوظيفية لتحويل تسلسلات البيانات وتحويل التدفقات الباردة إلى حاويات حالة ساخنة. كما يوضح استراتيجيات للتعامل مع عمليات الشبكة، مثل تنفيذ عمليات إعادة المحاولة مع التراجع الأسي، وإدارة مهلات الطلبات، واستخدام التخزين المحلي للوصول إلى البيانات في وضع عدم الاتصال أولاً. يتضمن المستودع أنماط اختبار متخصصة للتحقق من صحة المنطق متعدد الخيوط والسلوك غير المتزامن.