#reactive-streams (27 Repositories)
Ranked open-source repositories tagged with #reactive-streams, scored by pull request acceptance likelihood and maintainer engagement velocity.
41.9%
37.1h
27 repositories tagged #reactive-streams
akka/alpakka-kafka
Alpakka Kafka connector - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.
ReactiveX/RxJava
RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM.
apple/servicetalk
A networking framework that evolves with your application
crobox/clickhouse-scala-client
Clickhouse Scala Client with Reactive Streams support
reactor/reactor-netty
TCP/HTTP/UDP/QUIC client/server with Reactor over Netty
softwaremill/ox
Safe direct-style streaming, concurrency and resiliency for Scala on the JVM
Philippus/elastic4s
🔍 Elasticsearch Scala Client - Reactive, Non Blocking, Type Safe, HTTP Client
akka/akka-grpc
A platform to build and run apps that are elastic, agile, and resilient. SDK, libraries, and hosted environments.
akarnokd/RxJavaExtensions
RxJava 4.x extra sources, operators and components and ports of many 1.x companion libraries.
playframework/play-ws
Standalone Play WS, an async HTTP client with fluent API
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
monix/monix
Asynchronous, Reactive Programming for Scala and Scala.js.
akka/alpakka
Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.
smallrye/smallrye-mutiny
An Intuitive Event-Driven Reactive Programming Library for Java
raquo/Airstream
State propagation and event streams with mandatory ownership and no glitches
reactor/reactor-core
Non-Blocking Reactive Foundation for the JVM
raquo/Laminar
Simple, expressive, and safe UI library for Scala.js
softwaremill/kmq
Kafka-based message queue
outworkers/phantom
Schema safe, type-safe, reactive Scala driver for Cassandra/Datastax Enterprise
r2dbc/r2dbc-spi
Service Provider Interface for R2DBC Implementations
leonoel/missionary
A functional effect and streaming system for Clojure/Script
reactor/reactor-addons
Additional optional modules for the Reactor project
jetlinks/rule-engine
基于流程,事件驱动,可拓展,响应式,轻量级的规则引擎。
schananas/practical-reactor
Practical Project Reactor and reactive programing workshop
hantsy/spring-reactive-sample
Spring Reactive playground
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
CleverCloud/pulsar4s
Idiomatic, typesafe, and reactive Scala client for Apache Pulsar