reactive-streams

There are 533 repositories under reactive-streams topic.

  • ReactiveX/RxJava

    RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM.

    Language:Java48.4k2.2k3.2k7.6k

  • hs-web/hsweb-framework

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

    Language:Java8.4k7021773k

  • jetlinks/jetlinks-community

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

    Language:Java6.2k1404191.8k

  • reactor/reactor-core

    Non-Blocking Reactive Foundation for the JVM

    Language:Java5.2k1681.9k1.2k

  • uber/AutoDispose

    Automatic binding+disposal of RxJava streams.

    Language:Java3.4k65177229

  • ReactiveCocoa/ReactiveSwift

    Streams of values over time

    Language:Swift3k70291432

  • reactor/reactor-netty

    TCP/HTTP/UDP/QUIC client/server with Reactor over Netty

    Language:Java2.7k1071.4k687

  • monix/monix

    Asynchronous, Reactive Programming for Scala and Scala.js.

    Language:Scala1.9k57663245

  • CombineCommunity/CombineExt

    CombineExt provides a collection of operators, publishers and utilities for Combine, that are not provided by Apple themselves, but are common in other Reactive Frameworks and standards.

    Language:Swift1.8k3059162

  • Philippus/elastic4s

    🔍 Elasticsearch Scala Client - Reactive, Non Blocking, Type Safe, HTTP Client

    Language:Scala1.6k681.2k690

  • softwaremill/sttp

    The Scala HTTP client you always wanted!

    Language:Scala1.5k35472328
  • alpakka-kafka

    akka/alpakka-kafka

    Alpakka Kafka connector - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.

    Language:Scala1.4k73547378

  • hantsy/spring-reactive-sample

    Spring 5/6 Reactive playground

    Language:Java1.4k5518463

  • aol/cyclops

    An advanced, but easy to use, platform for writing functional applications in Java 8.

    Language:Java1.3k99764138
  • alpakka

    akka/alpakka

    Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.

    Language:Scala1.3k551.2k638

  • pgjdbc/r2dbc-postgresql

    Postgresql R2DBC Driver

    Language:Java1.1k50459188

  • CombineCommunity/RxCombine

    Bi-directional type bridging between RxSwift and Apple's Combine framework

    Language:Swift1k231492

  • outworkers/phantom

    Schema safe, type-safe, reactive Scala driver for Cassandra/Datastax Enterprise

    Language:Scala1k72422186
  • hivemq-mqtt-client

    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

    Language:Java1k52378175

  • apple/servicetalk

    A networking framework that evolves with your application

    Language:Java99239280201
  • smallrye-mutiny

    smallrye/smallrye-mutiny

    An Intuitive Event-Driven Reactive Programming Library for Java

    Language:Java89423319138

  • akarnokd/RxJavaInterop

    Library to convert between RxJava 1.x and 2.x/3.x reactive types, schedulers and resource handles.

    Language:Java862262157
  • Laminar

    raquo/Laminar

    Simple, expressive, and safe UI library for Scala.js

    Language:Scala8102411156

  • leonoel/missionary

    A functional effect and streaming system for Clojure/Script

    Language:Clojure7462710730

  • akarnokd/RxJavaExtensions

    RxJava 2.x & 3.x extra sources, operators and components and ports of many 1.x companion libraries.

    Language:Java684172751

  • mirromutth/r2dbc-mysql

    R2DBC MySQL Implementation

    Language:Java6522515599
  • scalecube-services

    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

    Language:Java63447191111

  • jetlinks/jetlinks

    JetLinks Core

    5174910277
  • ro

    samber/ro

    🏎️ Reactive Programming paradigm for Go: declarative and composable API for event-driven applications

    Language:Go500311916

  • softwaremill/ox

    Safe direct-style streaming, concurrency and resiliency for Scala on the JVM

    Language:Scala466246532

  • shamansir/rpd

    :ok_hand: A Minimal Engine for creating Node-Based Visual Programming User Interfaces

    Language:JavaScript4482342646

  • tcldr/Entwine

    Testing tools and utilities for Apple's Combine framework.

    Language:Swift44891524

  • schananas/practical-reactor

    Practical Project Reactor and reactive programing workshop

    Language:Java44168864

  • r2dbc/r2dbc-spi

    Service Provider Interface for R2DBC Implementations

    Language:Java4333318558
  • akka-grpc

    akka/akka-grpc

    A platform to build and run apps that are elastic, agile, and resilient. SDK, libraries, and hosted environments.

    Language:Scala43220574127

  • davidmoten/rxjava2-jdbc

    RxJava2 integration with JDBC including Non-blocking Connection Pools

    Language:Java395255741