搜索结果:reactive-streams(6 个)
按分类缩小范围
elastic4s
综合 64
elastic4s 解决了官方 Java 客户端在 Scala 中语法冗长、类型体验不佳的问题。它是专为 Scala 打造的响应式、非阻塞 Elasticsearch HTTP 客户端,提供类型安全且简洁的 DSL;原生支持 Scala 集合、Future 与常见 JSON 库(如 Circe、PlayJson),可在编译期捕获错误并安全复用请求。
sttp
综合 60
sttp 是一款专为 Scala 设计的 HTTP 客户端库。它解决了 Scala 生态中网络请求调用繁琐、技术栈割裂的问题。核心功能包括:提供统一易用的 API,支持同步、Future 及各类函数式 Effect(如 cats-effect、ZIO);兼容 OkHttp 等多种底层后端;支持 URI 插值、JSON 自动编解码、流式传输、文件收发与 WebSocket。
ox
综合 58
Ox 是面向 Scala 3 和 JDK 21+ 的并发与流处理库。它基于 JVM 虚拟线程,让开发者无需复杂的异步语法,就能以直观的“直接风格”编写高并发代码。核心功能包括结构化并发(安全管理生命周期与异常)、带背压的流处理,以及熔断、重试、限流等容错韧性机制。
alpakka
综合 56
Alpakka 是面向 Java 和 Scala 的响应式企业集成库。它基于 Akka Streams 和 Reactive Streams 构建,专为解决微服务、云环境与异构旧系统之间的数据集成问题。其核心功能是提供原生支持背压(Backpressure)的流式集成管道与 DSL,防止数据交互时系统过载。
alpakka-kafka
综合 55
Alpakka Kafka 是面向 Java 和 Scala 的 Kafka 连接器。它主要解决 Kafka 与响应式流(Reactive Streams)系统的集成问题,通过将 Apache Kafka 无缝接入 Akka Streams,提供原生支持背压(Backpressure)的流式数据处理能力。
akka-grpc
综合 51
〔中文简介暂未生成〕 A platform to build and run apps that are elastic, agile, and resilient. SDK, libraries, and hosted environments.