Awesome GitHub RepositoriesStream Processors

This project serves as a comprehensive language ecosystem index, functioning as a centralized, community-curated directory for the Go programming language. It organizes a vast landscape of software components, libraries, and development tools into a structured, navigable hierarchy, enabling developers to efficiently discover resources tailored to specific functional domains. The repository distinguishes itself through a decentralized contribution model, where community-driven updates ensure the index remains current with the rapidly evolving software landscape. Beyond simple resource listing,

RxKotlin is a reactive programming library and asynchronous stream processor that provides Kotlin language extensions for composing event-based data streams. It serves as a set of Kotlin bindings for RxJava, allowing developers to transform, filter, and flatten sequences of data emitted over time. The library focuses on integrating RxJava patterns into Kotlin projects by applying language-specific conventions and idioms. It utilizes extension functions to simplify reactive programming patterns, reduce boilerplate, and optimize workflows within the reactive ecosystem. The toolkit covers a bro

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

Bond هو إطار عمل ربط بيانات Swift مصمم لمزامنة نماذج البيانات وعناصر واجهة المستخدم من خلال تدفقات قيم أحادية وثنائية الاتجاه. يعمل كمجموعة تفاعلية لمراقبة تغييرات المجموعة، وتحويل تدفقات البيانات، وربط أحداث واجهة المستخدم بنماذج البيانات. يوفر المشروع جسراً تفاعلياً يحول تفاعلات واجهة المستخدم واستدعاءات طريقة تفويض البروتوكول إلى إشارات قابلة للمراقبة. يتضمن مراقباً للمجموعة لمراقبة التغييرات في المصفوفات ومعالج تدفق بيانات وظيفي يطبق مشغلين لتعديل أو دمج القيم قبل وصولها إلى عنصر واجهة مستخدم مستهدف. يغطي إطار العمل مجالات إمكانية واسعة بما في ذلك المزامنة على مستوى الخاصية، وربط مصدر البيانات التلقائي لعروض الجدول والمجموعة، وتحويل استدعاءات طريقة التفويض إلى أحداث إشارة غير متزامنة.