Awesome GitHub RepositoriesReactiveX Implementations

RxGo هي مكتبة برمجة تفاعلية وظيفية وتنفيذ لـ ReactiveX للغة Go. تعمل كمجموعة أدوات لمعالجة التدفق غير المتزامن مصممة لتنسيق البرامج القائمة على الأحداث وتدفقات البيانات باستخدام نمط الملاحظ (observable). تمكن المكتبة من بناء خطوط أنابيب معالجة غير متزامنة تقوم بتحويل وتصفية ودمج تسلسلات الأحداث. وتتميز باستخدام عوامل وظيفية لتكوين خطوط الأنابيب هذه وتوفر آليات لإدارة التنفيذ المتزامن. تغطي مجموعة الأدوات مجموعة واسعة من إمكانات تنسيق التدفق، بما في ذلك تجميع البيانات، ودمج التدفقات المتعددة، وتحويل التدفقات إلى هياكل بيانات ثابتة. وتتضمن دعماً مدمجاً لاستعادة الأخطاء، والتحكم في الضغط العكسي (backpressure) لتنظيم سرعات إنتاج البيانات، وتجميع العمال (worker pooling) لموازاة المعالجة عبر أنوية وحدة المعالجة المركزية.

RxPY هي مكتبة للبرمجة التفاعلية الوظيفية ومكتبة ReactiveX للملاحظات (Observable) في Python. تعمل كمعالج تدفق غير متزامن وإطار عمل تنسيق قائم على الأحداث، وتُستخدم لبناء خطوط أنابيب بيانات تتفاعل مع تغيرات الحالة أو تدفقات الأحداث بمرور الوقت. توفر المكتبة مجموعة أدوات لتأليف البرامج غير المتزامنة والقائمة على الأحداث باستخدام تسلسلات قابلة للملاحظة وعوامل تشغيل. تتميز باستخدام مجدولات (Schedulers) قابلة للتكوين لإدارة التزامن والتوقيت ودورات حياة الاشتراك. يغطي المشروع مجموعة واسعة من قدرات معالجة التدفق، بما في ذلك تجميع البيانات، والتصفية، والدمج. كما يوفر آليات لبث الأحداث، وتخزين التسلسلات مؤقتًا، ومعالجة الأخطاء، بالإضافة إلى أدوات لتنسيق التدفقات القابلة للملاحظة مع حلقات الأحداث غير المتزامنة. يتم دعم الاختبار وضمان الجودة من خلال محاكاة الوقت الافتراضي، ونمذجة مخططات الرخام (Marble diagrams)، والتحقق من الانبعاثات.