reactive-streams | Topic | Ecosyste.ms: Repos

Topic: "reactive-streams"

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: Java - Size: 138 MB - Last synced at: 10 days ago - Pushed at: 10 days ago - Stars: 48,156 - Forks: 7,603

hs-web/hsweb-framework

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

Language: Java - Size: 32.4 MB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 8,367 - Forks: 3,047

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

Language: Java - Size: 67.5 MB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 6,001 - Forks: 1,774

reactor/reactor-core

Non-Blocking Reactive Foundation for the JVM

Language: Java - Size: 62.6 MB - Last synced at: 2 days ago - Pushed at: 5 days ago - Stars: 5,100 - Forks: 1,226

uber/AutoDispose

Automatic binding+disposal of RxJava streams.

Language: Java - Size: 11.9 MB - Last synced at: 6 days ago - Pushed at: 11 months ago - Stars: 3,370 - Forks: 230

ReactiveCocoa/ReactiveSwift

Streams of values over time

Language: Swift - Size: 16.8 MB - Last synced at: 4 days ago - Pushed at: 13 days ago - Stars: 3,029 - Forks: 434

reactor/reactor-netty

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

Language: Java - Size: 26.4 MB - Last synced at: 10 days ago - Pushed at: 10 days ago - Stars: 2,682 - Forks: 674

monix/monix

Asynchronous, Reactive Programming for Scala and Scala.js.

Language: Scala - Size: 16.8 MB - Last synced at: 6 days ago - Pushed at: 10 months ago - Stars: 1,932 - Forks: 246

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: Swift - Size: 346 KB - Last synced at: about 1 month ago - Pushed at: about 1 year ago - Stars: 1,769 - Forks: 161

Philippus/elastic4s

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

Language: Scala - Size: 13.1 MB - Last synced at: 8 days ago - Pushed at: 8 days ago - Stars: 1,640 - Forks: 691

softwaremill/sttp

The Scala HTTP client you always wanted!

Language: Scala - Size: 10.8 MB - Last synced at: 8 days ago - Pushed at: 8 days ago - Stars: 1,477 - Forks: 322

akka/alpakka-kafka

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

Language: Scala - Size: 4.55 MB - Last synced at: 13 days ago - Pushed at: 13 days ago - Stars: 1,414 - Forks: 384

hantsy/spring-reactive-sample

Spring 5/6 Reactive playground

Language: Java - Size: 3.56 MB - Last synced at: 21 days ago - Pushed at: 21 days ago - Stars: 1,353 - Forks: 464

aol/cyclops

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

Language: Java - Size: 26.7 MB - Last synced at: 24 days ago - Pushed at: over 2 years ago - Stars: 1,327 - Forks: 138

akka/alpakka

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

Language: Scala - Size: 91.6 MB - Last synced at: 25 days ago - Pushed at: 27 days ago - Stars: 1,264 - Forks: 642

outworkers/phantom

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

Language: Scala - Size: 6.77 MB - Last synced at: 24 days ago - Pushed at: about 2 years ago - Stars: 1,047 - Forks: 186

pgjdbc/r2dbc-postgresql

Postgresql R2DBC Driver

Language: Java - Size: 3.44 MB - Last synced at: about 1 month ago - Pushed at: 8 months ago - Stars: 1,043 - Forks: 186

CombineCommunity/RxCombine

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

Language: Swift - Size: 914 KB - Last synced at: 3 days ago - Pushed at: about 1 year ago - Stars: 1,043 - Forks: 92

apple/servicetalk

A networking framework that evolves with your application

Language: Java - Size: 69 MB - Last synced at: 9 days ago - Pushed at: 9 days ago - Stars: 965 - Forks: 193

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: Java - Size: 7.7 MB - Last synced at: 13 days ago - Pushed at: 13 days ago - Stars: 945 - Forks: 167

akarnokd/RxJavaInterop

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

Language: Java - Size: 396 KB - Last synced at: 12 days ago - Pushed at: about 2 years ago - Stars: 862 - Forks: 57

smallrye/smallrye-mutiny

An Intuitive Event-Driven Reactive Programming Library for Java

Language: Java - Size: 23.3 MB - Last synced at: 6 days ago - Pushed at: 9 days ago - Stars: 855 - Forks: 134

raquo/Laminar

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

Language: Scala - Size: 9.48 MB - Last synced at: 15 days ago - Pushed at: 2 months ago - Stars: 797 - Forks: 58

leonoel/missionary

A functional effect and streaming system for Clojure/Script

Language: Clojure - Size: 551 KB - Last synced at: 2 days ago - Pushed at: 9 days ago - Stars: 735 - Forks: 30

akarnokd/RxJavaExtensions

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

Language: Java - Size: 9.04 MB - Last synced at: 30 days ago - Pushed at: about 2 years ago - Stars: 686 - Forks: 51

mirromutth/r2dbc-mysql 📦

R2DBC MySQL Implementation

Language: Java - Size: 2.08 MB - Last synced at: about 2 months ago - Pushed at: over 1 year ago - Stars: 655 - Forks: 97

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: Java - Size: 6.78 MB - Last synced at: 4 days ago - Pushed at: 4 days ago - Stars: 622 - Forks: 107

jetlinks/jetlinks

JetLinks Core

Size: 269 KB - Last synced at: 11 days ago - Pushed at: 11 days ago - Stars: 508 - Forks: 272

shamansir/rpd

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

Language: JavaScript - Size: 17.7 MB - Last synced at: 6 days ago - Pushed at: about 1 month ago - Stars: 448 - Forks: 46

tcldr/Entwine

Testing tools and utilities for Apple's Combine framework.

Language: Swift - Size: 7.35 MB - Last synced at: 29 days ago - Pushed at: over 1 year ago - Stars: 448 - Forks: 24

akka/akka-grpc

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

Language: Scala - Size: 4.75 MB - Last synced at: 13 days ago - Pushed at: 13 days ago - Stars: 432 - Forks: 127

r2dbc/r2dbc-spi

Service Provider Interface for R2DBC Implementations

Language: Java - Size: 762 KB - Last synced at: about 1 month ago - Pushed at: 7 months ago - Stars: 426 - Forks: 57

davidmoten/rxjava2-jdbc

RxJava2 integration with JDBC including Non-blocking Connection Pools

Language: Java - Size: 1.42 MB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 393 - Forks: 41

spring-attic/reactive-streams-commons 📦

A joint research effort for building highly optimized Reactive-Streams compliant operators.

Language: Java - Size: 2.28 MB - Last synced at: about 1 year ago - Pushed at: over 3 years ago - Stars: 355 - Forks: 51

r2dbc/r2dbc-client 📦

Reactive Relational Database Connectivity

Language: Java - Size: 744 KB - Last synced at: 2 months ago - Pushed at: almost 5 years ago - Stars: 344 - Forks: 24

schananas/practical-reactor

Practical Project Reactor and reactive programing workshop

Language: Java - Size: 1.69 MB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 341 - Forks: 635

softwaremill/kmq

Kafka-based message queue

Language: Scala - Size: 454 KB - Last synced at: 4 days ago - Pushed at: 4 days ago - Stars: 337 - Forks: 45

jetlinks/rule-engine

基于流程,事件驱动,可拓展,响应式,轻量级的规则引擎。

Language: Java - Size: 737 KB - Last synced at: 3 days ago - Pushed at: 4 days ago - Stars: 299 - Forks: 175

LoopPerfect/rxterm

Functional reactive terminals in C++ ⚡⌨️

Language: C++ - Size: 58.6 KB - Last synced at: over 1 year ago - Pushed at: about 4 years ago - Stars: 262 - Forks: 28

raquo/Airstream

State propagation and event streams with mandatory ownership and no glitches

Language: Scala - Size: 1.69 MB - Last synced at: 15 days ago - Pushed at: about 2 months ago - Stars: 256 - Forks: 30

asyncer-io/r2dbc-mysql

Reactive Relational Database Connectivity for MySQL. The official successor to mirromutth/r2dbc-mysql(dev.miku:r2dbc-mysql).

Language: Java - Size: 2.95 MB - Last synced at: 14 days ago - Pushed at: about 1 month ago - Stars: 243 - Forks: 25

reactor/reactor-addons

Additional optional modules for the Reactor project

Language: Java - Size: 5.96 MB - Last synced at: 10 days ago - Pushed at: 10 days ago - Stars: 237 - Forks: 83

ReactiveX/RxJavaReactiveStreams

Adapter between RxJava and ReactiveStreams

Language: Java - Size: 306 KB - Last synced at: 2 days ago - Pushed at: over 7 years ago - Stars: 234 - Forks: 31

CleverCloud/pulsar4s

Idiomatic, typesafe, and reactive Scala client for Apache Pulsar

Language: Scala - Size: 856 KB - Last synced at: 15 days ago - Pushed at: 30 days ago - Stars: 230 - Forks: 45

playframework/play-ws

Standalone Play WS, an async HTTP client with fluent API

Language: Scala - Size: 2.36 MB - Last synced at: 1 day ago - Pushed at: 12 days ago - Stars: 225 - Forks: 87

r2dbc/r2dbc-h2

R2DBC H2 Implementation

Language: Java - Size: 729 KB - Last synced at: 29 days ago - Pushed at: about 1 year ago - Stars: 206 - Forks: 46

oracle/oracle-r2dbc

R2DBC Driver for Oracle Database

Language: Java - Size: 1.03 MB - Last synced at: 24 days ago - Pushed at: 7 months ago - Stars: 205 - Forks: 43

mostafacs/ecommerce-microservices-spring-reactive-webflux

E-commerce demo with spring reactive webflux and spring cloud microservice

Language: Java - Size: 106 KB - Last synced at: about 1 month ago - Pushed at: almost 2 years ago - Stars: 203 - Forks: 101

stefan-zobel/streamsupport 📦

Backport of Java 8/9 java.util.stream API to Java 6/7 and Android

Language: Java - Size: 3.72 MB - Last synced at: 4 months ago - Pushed at: over 1 year ago - Stars: 188 - Forks: 29

lucamezzalira/awesome-reactive-programming

A repository for sharing all the resources available on Reactive Programming and Reactive Systems

Size: 17.6 KB - Last synced at: about 1 month ago - Pushed at: almost 6 years ago - Stars: 186 - Forks: 26

observable-playground/observable-playground

Know your Observables before deploying to production

Language: JavaScript - Size: 3.17 MB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 185 - Forks: 13

LearningByExample/reactive-ms-example

An educational project to learn reactive programming with Spring 5

Language: Java - Size: 671 KB - Last synced at: 3 months ago - Pushed at: about 7 years ago - Stars: 174 - Forks: 75

rsocket/rsocket-rpc-java

Standard RSocket RPC Java Implementation

Language: Java - Size: 415 KB - Last synced at: about 1 month ago - Pushed at: over 2 years ago - Stars: 171 - Forks: 41

davidmoten/rxjava2-extras

Utilities for use with RxJava 2

Language: Java - Size: 2.17 MB - Last synced at: 12 days ago - Pushed at: 12 days ago - Stars: 170 - Forks: 16

callicoder/spring-webflux-reactive-rest-api-demo

Build Reactive Rest APIs with Spring WebFlux and Reactive Mongo

Language: Java - Size: 61.5 KB - Last synced at: 2 months ago - Pushed at: over 3 years ago - Stars: 160 - Forks: 135

ReactivePlatform/Reactive-Design-Patterns Fork of ReactiveDesignPatterns/CodeSamples

《反应式设计模式》中文版代码清单勘误地址=>

Language: Scala - Size: 3.14 MB - Last synced at: 3 months ago - Pushed at: about 2 years ago - Stars: 158 - Forks: 27

r2dbc/r2dbc-proxy

R2DBC Proxying Framework

Language: Java - Size: 7.44 MB - Last synced at: 27 days ago - Pushed at: about 2 months ago - Stars: 149 - Forks: 22

pellse/assembler

Assembler is a reactive data aggregation library for querying and merging data from multiple data sources/services. Assembler enables efficient implementation of the API Composition Pattern and is also designed to solve the N + 1 query problem. Architecture-agnostic, it can be used as part of a monolithic or microservice architecture.

Language: Java - Size: 24.4 MB - Last synced at: 9 days ago - Pushed at: 24 days ago - Stars: 128 - Forks: 16

crobox/clickhouse-scala-client

Clickhouse Scala Client with Reactive Streams support

Language: Scala - Size: 1.37 MB - Last synced at: 12 days ago - Pushed at: 12 days ago - Stars: 116 - Forks: 27

andifalk/reactive-spring-security-5-workshop

Hands-On workshop for securing a reactive spring boot 2 application in multiple steps

Language: Java - Size: 32.1 MB - Last synced at: 2 months ago - Pushed at: over 1 year ago - Stars: 108 - Forks: 46

monkey-codes/java-reactive-chat

A Simple Chat App using WebFlux (Reactive Streams), WebSockets and a React frontend.

Language: JavaScript - Size: 272 KB - Last synced at: about 1 year ago - Pushed at: almost 2 years ago - Stars: 108 - Forks: 42

tomasfabian/ksqlDB.RestApi.Client-DotNet

ksqlDb.RestApi.Client is a C# LINQ-enabled client API for issuing and consuming ksqlDB push and pull queries and executing statements.

Language: C# - Size: 11.2 MB - Last synced at: 22 days ago - Pushed at: 27 days ago - Stars: 100 - Forks: 25

ZhongyangMA/webflux-streaming-demo

A tryout of reactive application using Spring 5 WebFlux and mongoDB, along with an overview article on reactive programming.

Language: Java - Size: 28.3 KB - Last synced at: 2 months ago - Pushed at: over 4 years ago - Stars: 96 - Forks: 27

rucek/akka-streams-in-practice

Import data from CSV files to Cassandra using Akka Streams

Language: Scala - Size: 84 KB - Last synced at: over 2 years ago - Pushed at: over 6 years ago - Stars: 88 - Forks: 22

danielfernandez/reactive-matchday

Spring 5 showcase application with a Thymeleaf HTML5 interface

Language: Java - Size: 301 KB - Last synced at: 3 months ago - Pushed at: over 7 years ago - Stars: 83 - Forks: 21

River-Kt/river

Extensions & Enterprise Integrations for Kotlin flows

Language: Kotlin - Size: 4.92 MB - Last synced at: 10 months ago - Pushed at: 10 months ago - Stars: 79 - Forks: 3

learning-spring-boot/learning-spring-boot-2nd-edition-code

Source code for Learning Spring Boot 2nd Edition

Language: Java - Size: 5.1 MB - Last synced at: 3 months ago - Pushed at: almost 6 years ago - Stars: 76 - Forks: 32

mongodb/mongo-java-driver-reactivestreams 📦

The MongoDB Reactive Streams Driver has been moved here: https://github.com/mongodb/mongo-java-driver, and this repository has been archived.

Language: Java - Size: 2.6 MB - Last synced at: 3 months ago - Pushed at: 11 months ago - Stars: 73 - Forks: 43

lucassklp/Rx.Http

A reactive way to make HTTP Request in .NET Core 🚀

Language: C# - Size: 2.28 MB - Last synced at: 14 days ago - Pushed at: 12 months ago - Stars: 73 - Forks: 8

jetty-project/jetty-reactive-httpclient

Jetty ReactiveStreams HttpClient

Language: Java - Size: 942 KB - Last synced at: 18 days ago - Pushed at: 18 days ago - Stars: 72 - Forks: 13

akarnokd/RxJavaJdk8Interop

RxJava 2/3 interop library for supporting Java 8 features such as Optional, Stream and CompletableFuture [discontinued]

Language: Java - Size: 534 KB - Last synced at: 15 days ago - Pushed at: over 5 years ago - Stars: 71 - Forks: 6

akka/alpakka-samples

Example projects building Reactive Integrations using Alpakka

Language: Java - Size: 1.2 MB - Last synced at: 1 day ago - Pushed at: about 2 months ago - Stars: 68 - Forks: 37

apache/pekko-connectors

Apache Pekko Connectors is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Apache Pekko.

Language: Scala - Size: 91.2 MB - Last synced at: about 6 hours ago - Pushed at: about 7 hours ago - Stars: 66 - Forks: 38

jjeffcaii/reactor-go

A golang implementation for reactive-streams.

Language: Go - Size: 393 KB - Last synced at: about 1 month ago - Pushed at: 3 months ago - Stars: 66 - Forks: 8

idugalic/reactive-company

Example of reactive web application. Java. Spring 5. Reactive Streams. Docker.

Language: Java - Size: 405 KB - Last synced at: 16 days ago - Pushed at: over 1 year ago - Stars: 66 - Forks: 21

apptik/RHub

Reactive Event Hub

Language: Java - Size: 1.16 MB - Last synced at: about 1 month ago - Pushed at: over 3 years ago - Stars: 65 - Forks: 5

CollaborationInEncapsulation/reactive-pacman Fork of knagaitsev/dinoman-io

Multiplayer Reactive Pac-Man with RSocket

Language: TypeScript - Size: 18.7 MB - Last synced at: over 2 years ago - Pushed at: over 4 years ago - Stars: 65 - Forks: 26

lightbend/reactive-streams-utils 📦

Language: Java - Size: 576 KB - Last synced at: about 2 months ago - Pushed at: about 6 years ago - Stars: 64 - Forks: 7

trishagee/jb-stock-client

This is a Spring Boot and JavaFX Application that uses REST or RSocket to connect to a streaming prices service and display the prices on a line chart

Language: Java - Size: 85.9 KB - Last synced at: over 1 year ago - Pushed at: over 2 years ago - Stars: 63 - Forks: 33

shiang/flutter-form-with-validation-BLOC

This form and validation functions are created by using the BLOC pattern with RxDart instead of using StatefulWidget

Language: Dart - Size: 104 KB - Last synced at: over 1 year ago - Pushed at: almost 7 years ago - Stars: 63 - Forks: 16

apache/pulsar-client-reactive

Reactive client for Apache Pulsar

Language: Java - Size: 614 KB - Last synced at: 7 days ago - Pushed at: 9 days ago - Stars: 62 - Forks: 20

monix/monix-connect

A set of connectors for Monix. 🔛

Language: Scala - Size: 8.56 MB - Last synced at: 3 months ago - Pushed at: 10 months ago - Stars: 60 - Forks: 17

ReactiveHTML/rimmel

A Streams-Oriented UI library for the Rx.Observable Universe.

Language: TypeScript - Size: 6.87 MB - Last synced at: 1 day ago - Pushed at: 1 day ago - Stars: 55 - Forks: 5

perkss/kotlin-kafka-and-kafka-streams-examples

Kafka with KafkaReactor and Kafka Streams Examples in Kotlin

Language: Kotlin - Size: 447 KB - Last synced at: 20 days ago - Pushed at: 6 months ago - Stars: 54 - Forks: 12

spring-attic/reactor-scala-extensions 📦

A scala extension for Project Reactor's Flux and Mono

Language: Scala - Size: 2.62 MB - Last synced at: about 1 year ago - Pushed at: over 3 years ago - Stars: 52 - Forks: 15

kosich/react-rxjs-elements

React component for RxJS content

Language: TypeScript - Size: 1.83 MB - Last synced at: 10 days ago - Pushed at: over 2 years ago - Stars: 51 - Forks: 1

hoc081098/flutter_validation_login_form_BLoC_pattern_RxDart

[Functional reactive programming (FRP)]💧 💧 💧 [Pure RxDart] Validation login form by using the BLoC pattern with RxDart - A new Flutter project featuring a faked authentication interface to demonstrate validation. Implemented with BloC pattern.

Language: Dart - Size: 5.19 MB - Last synced at: 21 days ago - Pushed at: 22 days ago - Stars: 50 - Forks: 12

tunjid/Mutator

Flow powered mutual exclusion for UI state mutation over time.

Language: Kotlin - Size: 13.3 MB - Last synced at: about 2 months ago - Pushed at: 2 months ago - Stars: 50 - Forks: 9

akarnokd/Reactive4JavaFlow

Reactive Programming library based on the Java 9 Flow API and a 4th generation ReactiveX-style architecture.

Language: Java - Size: 1.2 MB - Last synced at: 3 months ago - Pushed at: over 2 years ago - Stars: 50 - Forks: 2

juliuskrah/quartz-manager

Dynanic Job Scheduling with Quartz and Spring

Language: Java - Size: 1.45 MB - Last synced at: over 2 years ago - Pushed at: over 5 years ago - Stars: 50 - Forks: 38

datastax/reactive-pulsar

Reactive Streams adapter for Apache Pulsar Java Client

Language: Java - Size: 268 KB - Last synced at: about 2 months ago - Pushed at: about 2 years ago - Stars: 48 - Forks: 15

srpraneeth/spring5-reactive

Sample application for Spring5 Reactive web application

Language: Java - Size: 51.8 KB - Last synced at: about 1 year ago - Pushed at: about 8 years ago - Stars: 48 - Forks: 39

zio-archive/interop-reactive-streams 📦

Interoperability Layer Between ZIO and Reactive Streams

Language: Scala - Size: 341 KB - Last synced at: 3 days ago - Pushed at: about 1 year ago - Stars: 47 - Forks: 27

funcool/potok

Reactive streams based state management toolkit for ClojureScript

Language: Clojure - Size: 175 KB - Last synced at: 28 days ago - Pushed at: 6 months ago - Stars: 46 - Forks: 3

andywer/observable-fns

🕵️‍♀️ Light-weight observable implementation and functional utilities in TypeScript

Language: TypeScript - Size: 234 KB - Last synced at: 29 days ago - Pushed at: over 2 years ago - Stars: 46 - Forks: 1

apache/pekko-grpc

Apache Pekko gRPC

Language: Scala - Size: 3.85 MB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 45 - Forks: 20

netifi-proteus/proteus-java 📦

Proteus Java Client

Language: Java - Size: 1.23 MB - Last synced at: about 1 year ago - Pushed at: about 6 years ago - Stars: 43 - Forks: 3