reactive-streams

RxJava——JVM的响应式扩展库，通过可观察序列为Java虚拟机编写异步和基于事件的程序。

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

Apache Pekko Connectors 是一个基于响应式流和 Apache Pekko 的 Java 与 Scala 响应式企业集成库。

Apache Pekko gRPC

Apache Pekko Kafka连接器——Pekko连接器是基于响应式流与Apache Pekko的Java及Scala响应式企业集成库。