2 Repos
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
Finde die besten Repos mit KI.Wir suchen mit KI nach den am besten passenden Repositories.
- baconjs/bacon.js
baconjs/bacon.js
6,458Auf GitHub ansehenBacon.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,014Auf GitHub ansehenRxPY ist eine Bibliothek für funktionale reaktive Programmierung und eine ReactiveX-Observable-Bibliothek für Python. Sie dient als asynchroner Stream-Prozessor und ereignisgesteuertes Koordinations-Framework zum Aufbau von Datenpipelines, die auf Zustandsänderungen oder Ereignisströme im Zeitverlauf reagieren. Die Bibliothek bietet ein Toolkit zur Komposition asynchroner und ereignisbasierter Programme mittels beobachtbarer Sequenzen und Operatoren. Sie zeichnet sich durch konfigurierbare Scheduler aus, die Nebenläufigkeit, Timing und Abonnement-Lebenszyklen verwalten. Das Projekt deckt ein breites Spektrum an Stream-Processing-Funktionen ab, einschließlich Datenaggregation, Filterung und Kombination. Es bietet Mechanismen für Event-Broadcasting, Sequenz-Buffering und Fehlerbehandlung sowie Werkzeuge zur Koordination beobachtbarer Streams mit asynchronen Event-Loops. Tests und Qualitätssicherung werden durch virtuelle Zeitsimulation, Marble-Diagramm-Modellierung und Emissionsverifizierung unterstützt.
Joins multiple asynchronous streams such that each completes before the next begins in a strict sequential order.
Python
