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 的安全直接風格串流、並發與彈性處理