Reactive Streams
Showing 25 of 25 projects
A Java VM library for composing asynchronous and event-based programs using observable sequences.
A JVM library for composing asynchronous and event-based programs using observable sequences.
A standard specification for asynchronous stream processing with non-blocking backpressure on the JVM.
A Java library providing a consistent API for trading and accessing market data across 60+ cryptocurrency exchanges.
The official Java SDK for building and consuming Model Context Protocol servers and clients, enabling Java apps to interact with AI models.
A Swift framework for reactive and functional programming, providing composable primitives for streams of values over time.
A purely functional, effectful, and polymorphic stream processing library for Scala built on Cats and Cats-Effect.
A lightweight and efficient stream processing library for Go, providing a declarative DSL to build data pipelines.
A high-performance Scala library for composing asynchronous, event-based programs with strong functional programming influences.
A Reactive Streams connector for Apache Kafka built on Akka Streams, enabling back-pressured integration for Java and Scala.
A Java 8 library providing persistent data structures, functional control types, and higher-kinded abstractions for building functional applications.
A high-performance, feature-rich Java client library for MQTT 5.0 and 3.1.1 with multiple API flavors and backpressure support.
A fully non-blocking, asynchronous MongoDB driver for Scala built on reactive streams.
A suite of libraries for using gRPC with Reactive Streams programming models like RxJava and Spring Reactor.
A reactive dataflow programming toolkit for Clojure/Script providing functional effect and streaming primitives.
A Kotlin toolkit for MongoDB providing native extensions, object mapping, and type-safe queries.
A high-throughput, low-latency reactive microservices library with built-in service discovery, load balancing, and pluggable API gateways.
A high-throughput, low-latency reactive microservices library with built-in service discovery, load balancing, and pluggable API gateways.
A stream-based, strongly typed GraphQL client for Dart and Flutter with built-in code generation and normalized caching.
A distributed actor framework for Go that enables building scalable, reactive systems with typed messages and clustering.
A .NET standard for asynchronous stream processing with non-blocking backpressure, enabling interoperability between reactive libraries.
A Spring Framework library for building GraphQL schemas using annotations, with Relay support and reactive execution.
An Either type implementation for RxJava, enabling functional error handling and progress reporting in reactive streams.
A distributed data synchronization library using operational transformation and CRDTs for conflict-free merging of custom data structures.
A Flutter plugin for beacon ranging and monitoring on Android and iOS with automatic permission management.
Related Tags
Found a gem we're missing?
Open-Awesome is built by the community, for the community. Submit a project, suggest an awesome list, or help improve the catalog on GitHub.