2 repository-uri
Awesome GitHub RepositoriesDeclarative Stream Processing
Applying functional query operators to process asynchronous sequences of data.
Distinct from Query-to-Stream Adapters: None of the candidates cover the general application of LINQ-style operators to async streams; most are narrow AI or adapter patterns.
Explore 2 awesome GitHub repositories matching software engineering & architecture · Declarative Stream Processing. Refine with filters or upvote what's useful.
Awesome Declarative Stream Processing GitHub Repositories
Găsește cele mai bune repo-uri cu AI.Vom căuta cele mai potrivite repository-uri folosind AI.
- reactive-extensions/rx.net
Reactive-Extensions/Rx.NET
7,153Vezi pe GitHubRx.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
Apply standard query operators to asynchronous enumerables to process data streams in a declarative manner.
C# - ag2ai/faststream
ag2ai/faststream
4,967Vezi pe GitHubFastStream is an asyncio message broker framework for building event-driven applications in Python. It provides a unified interface and a multi-broker messaging abstraction layer that translates generic producer and consumer calls into broker-specific APIs. The framework features a built-in dependency injection container and uses decorators to route messages to asynchronous handler functions. It includes a documentation generator that extracts channel definitions and message formats from code to produce standardized AsyncAPI specifications. The project supports integration with Kafka, Rabbit
Processes streaming events by consuming messages and publishing responses using declarative decorators.
Pythonasyncapiasynciodistributed-systems
