2 مستودعات
Awesome GitHub RepositoriesSequential Stream Concatenation
Mechanisms for joining multiple asynchronous streams such that each completes before the next begins.
Distinct from Concatenated Streams: Distinct from network concatenated streams or file streaming; this is a general-purpose reactive stream orchestration pattern.
Explore 2 awesome GitHub repositories matching software engineering & architecture · Sequential Stream Concatenation. Refine with filters or upvote what's useful.
Awesome Sequential Stream Concatenation GitHub Repositories
اعثر على أفضل المستودعات باستخدام الذكاء الاصطناعي.سنبحث عن أفضل المستودعات المطابقة باستخدام الذكاء الاصطناعي.
- baconjs/bacon.js
baconjs/bacon.js
6,458عرض على GitHubBacon.js is a JavaScript functional reactive programming library used for coordinating complex asynchronous data flows. It functions as an observable event stream framework and an asynchronous data flow orchestrator, allowing developers to model events as declarative streams and properties. The library distinguishes itself through its ability to manage reactive state and synchronize timing across multiple sources. It provides specialized mechanisms for atomic state synchronization to prevent glitches in derived properties and offers advanced coordination strategies such as asynchronous stream
Implements a mechanism to subscribe to multiple event sources sequentially, ensuring each finishes before the next starts.
TypeScript - reactivex/rxpy
ReactiveX/RxPY
5,014عرض على GitHubRxPY هي مكتبة للبرمجة التفاعلية الوظيفية ومكتبة ReactiveX للملاحظات (Observable) في Python. تعمل كمعالج تدفق غير متزامن وإطار عمل تنسيق قائم على الأحداث، وتُستخدم لبناء خطوط أنابيب بيانات تتفاعل مع تغيرات الحالة أو تدفقات الأحداث بمرور الوقت. توفر المكتبة مجموعة أدوات لتأليف البرامج غير المتزامنة والقائمة على الأحداث باستخدام تسلسلات قابلة للملاحظة وعوامل تشغيل. تتميز باستخدام مجدولات (Schedulers) قابلة للتكوين لإدارة التزامن والتوقيت ودورات حياة الاشتراك. يغطي المشروع مجموعة واسعة من قدرات معالجة التدفق، بما في ذلك تجميع البيانات، والتصفية، والدمج. كما يوفر آليات لبث الأحداث، وتخزين التسلسلات مؤقتًا، ومعالجة الأخطاء، بالإضافة إلى أدوات لتنسيق التدفقات القابلة للملاحظة مع حلقات الأحداث غير المتزامنة. يتم دعم الاختبار وضمان الجودة من خلال محاكاة الوقت الافتراضي، ونمذجة مخططات الرخام (Marble diagrams)، والتحقق من الانبعاثات.
Joins multiple asynchronous streams such that each completes before the next begins in a strict sequential order.
Python
