reactive-streams

RxJava – JVM 的 Reactive Extensions – 一个使用可观察序列来组合异步和事件驱动程序的库，适用于 Java 虚拟机。

hsweb（haʊs wɛb）是一个基于 spring-boot 2.x 开发的企业级后台管理系统基础项目，首个使用全响应式编程的项目。

JetLinks 基于 Java、Spring Boot、WebFlux、Netty、Vert.x、Reactor 等开发，是一个全响应式的企业级物联网平台。支持统一物模型管理、多种设备、多种厂商、统一管理。统一设备连接管理，多协议适配（TCP、MQTT、UDP、CoAP、HTTP 等），屏蔽网络编程复杂性，灵活接入不同厂商不同协议等设备。实时数据处理、设备告警、消息通知、数据转发。地理位置、数据可视化等。能帮助你快速建立物联网相关业务系统。

JVM 的非阻塞反应式基础

RxJava 流的自动绑定与释放

随时间变化的值流

基于 Netty Reactor 的 TCP/HTTP/UDP/QUIC 客户端/服务端

适用于 Scala 与 Scala.js 的异步响应式编程。

CombineExt 为 Apple 未提供、但在其他 Reactive 框架和标准中常见的 Combine 提供了运算符、发布者和实用程序集合。

🔍 Elasticsearch Scala 客户端 - 响应式、非阻塞、类型安全、HTTP 客户端

你一直想要的 Scala HTTP 客户端！

Alpakka Kafka 连接器 - Alpakka 是一个基于 Reactive Streams 与 Akka 的 Java 和 Scala 反应式企业集成库。

Spring Reactive 练习场

Alpakka 是一个基于 Reactive Streams 与 Akka 的 Java 和 Scala 反应式企业集成库。

HiveMQ MQTT Client 是一个兼容 MQTT 5.0 与 MQTT 3.1.1、功能丰富且高性能的 Java 客户端库，提供不同的 API 风格与背压支持

PostgreSQL R2DBC 驱动程序

RxSwift 与 Apple 的 Combine 框架之间的双向类型桥接

随应用程序一同演进的网络框架

适用于 Java 的直观事件驱动响应式编程库

为 Scala.js 设计的简单、具表达力且安全的 UI 库

适用于 Clojure/Script 的函数式效应与流系统

🏎️ Go 语言的流与响应式编程范式：适用于事件驱动应用程序的声明式与可组合 API

RxJava 4.x 的额外来源、运算符、组件以及许多 1.x 附属库的移植。

微服务 library - scalecube-services 是一个高吞吐量、低延迟的反应式微服务 library，专为扩展而构建。其特点包括：API-Gateways、服务发现、服务负载均衡，架构支持即插即用服务通信模块与功能，旨在提供高性能与低延迟的实时流处理

JetLinks 核心组件

JVM 上 Scala 的安全直接风格流、并发与弹性处理