reactive-streams
There are 529 repositories under reactive-streams topic.
ReactiveX/RxJava
RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM.
hs-web/hsweb-framework
hsweb (haʊs wɛb) 是一个基于spring-boot 2.x开发 ,首个使用全响应式编程的企业级后台管理系统基础项目。
jetlinks/jetlinks-community
JetLinks 基于Java,Spring Boot ,WebFlux,Netty,Vert.x,Reactor等开发, 是一个全响应式的企业级物联网平台。支持统一物模型管理,多种设备,多种厂家,统一管理。统一设备连接管理,多协议适配(TCP,MQTT,UDP,CoAP,HTTP等),屏蔽网络编程复杂性,灵活接入不同厂家不同协议等设备。实时数据处理,设备告警,消息通知,数据转发。地理位置,数据可视化等。能帮助你快速建立物联网相关业务系统。
reactor/reactor-core
Non-Blocking Reactive Foundation for the JVM
uber/AutoDispose
Automatic binding+disposal of RxJava streams.
ReactiveCocoa/ReactiveSwift
Streams of values over time
reactor/reactor-netty
TCP/HTTP/UDP/QUIC client/server with Reactor over Netty
monix/monix
Asynchronous, Reactive Programming for Scala and Scala.js.
CombineCommunity/CombineExt
CombineExt provides a collection of operators, publishers and utilities for Combine, that are not provided by Apple themselves, but are common in other Reactive Frameworks and standards.
Philippus/elastic4s
🔍 Elasticsearch Scala Client - Reactive, Non Blocking, Type Safe, HTTP Client
softwaremill/sttp
The Scala HTTP client you always wanted!
akka/alpakka-kafka
Alpakka Kafka connector - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.
hantsy/spring-reactive-sample
Spring 5/6 Reactive playground
aol/cyclops
An advanced, but easy to use, platform for writing functional applications in Java 8.
akka/alpakka
Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.
pgjdbc/r2dbc-postgresql
Postgresql R2DBC Driver
CombineCommunity/RxCombine
Bi-directional type bridging between RxSwift and Apple's Combine framework
outworkers/phantom
Schema safe, type-safe, reactive Scala driver for Cassandra/Datastax Enterprise
apple/servicetalk
A networking framework that evolves with your application
hivemq/hivemq-mqtt-client
HiveMQ MQTT Client is an MQTT 5.0 and MQTT 3.1.1 compatible and feature-rich high-performance Java client library with different API flavours and backpressure support
smallrye/smallrye-mutiny
An Intuitive Event-Driven Reactive Programming Library for Java
akarnokd/RxJavaInterop
Library to convert between RxJava 1.x and 2.x/3.x reactive types, schedulers and resource handles.
raquo/Laminar
Simple, expressive, and safe UI library for Scala.js
leonoel/missionary
A functional effect and streaming system for Clojure/Script
akarnokd/RxJavaExtensions
RxJava 2.x & 3.x extra sources, operators and components and ports of many 1.x companion libraries.
mirromutth/r2dbc-mysql
R2DBC MySQL Implementation
scalecube/scalecube-services
Microservices library - scalecube-services is a high throughput, low latency reactive microservices library built to scale. It features: API-Gateways, service-discovery, service-load-balancing, the architecture supports plug-and-play service communication modules and features. built to provide performance and low-latency real-time stream-processing
jetlinks/jetlinks
JetLinks Core
softwaremill/ox
Safe direct-style streaming, concurrency and resiliency for Scala on the JVM
tcldr/Entwine
Testing tools and utilities for Apple's Combine framework.
shamansir/rpd
:ok_hand: A Minimal Engine for creating Node-Based Visual Programming User Interfaces
schananas/practical-reactor
Practical Project Reactor and reactive programing workshop
akka/akka-grpc
A platform to build and run apps that are elastic, agile, and resilient. SDK, libraries, and hosted environments.
r2dbc/r2dbc-spi
Service Provider Interface for R2DBC Implementations
davidmoten/rxjava2-jdbc
RxJava2 integration with JDBC including Non-blocking Connection Pools
spring-attic/reactive-streams-commons
A joint research effort for building highly optimized Reactive-Streams compliant operators.