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: 137 MB - Last synced at: 6 days ago - Pushed at: 7 days ago - Stars: 48,077 - Forks: 7,609

hs-web/hsweb-framework

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

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

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

Language: Java - Size: 66.4 MB - Last synced at: 3 days ago - Pushed at: 4 days ago - Stars: 5,863 - Forks: 1,743

reactor/reactor-core

Non-Blocking Reactive Foundation for the JVM

Language: Java - Size: 62.7 MB - Last synced at: 3 days ago - Pushed at: 7 days ago - Stars: 5,070 - Forks: 1,220

uber/AutoDispose

Automatic binding+disposal of RxJava streams.

Language: Java - Size: 11.9 MB - Last synced at: 4 days ago - Pushed at: 9 months ago - Stars: 3,371 - Forks: 229

ReactiveCocoa/ReactiveSwift

Streams of values over time

Language: Swift - Size: 16.8 MB - Last synced at: 4 days ago - Pushed at: 2 months ago - Stars: 3,024 - Forks: 432

reactor/reactor-netty

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

Language: Java - Size: 26.2 MB - Last synced at: 2 days ago - Pushed at: 4 days ago - Stars: 2,664 - Forks: 668

monix/monix

Asynchronous, Reactive Programming for Scala and Scala.js.

Language: Scala - Size: 16.8 MB - Last synced at: 13 days ago - Pushed at: 8 months ago - Stars: 1,935 - Forks: 245

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: 11 days ago - Pushed at: 10 months ago - Stars: 1,762 - Forks: 161

Philippus/elastic4s

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

Language: Scala - Size: 12.7 MB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 1,637 - Forks: 691

softwaremill/sttp

The Scala HTTP client you always wanted!

Language: Scala - Size: 10.7 MB - Last synced at: 3 days ago - Pushed at: 4 days ago - Stars: 1,468 - Forks: 318

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.48 MB - Last synced at: 11 days ago - Pushed at: 27 days ago - Stars: 1,415 - Forks: 386

hantsy/spring-reactive-sample

Spring 5/6 Reactive playground

Language: Java - Size: 3.52 MB - Last synced at: 10 days ago - Pushed at: 21 days ago - Stars: 1,346 - 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: 7 days ago - Pushed at: about 2 years ago - Stars: 1,323 - Forks: 137

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: 4 days ago - Pushed at: 4 days ago - Stars: 1,264 - Forks: 643

outworkers/phantom

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

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

CombineCommunity/RxCombine

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

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

pgjdbc/r2dbc-postgresql

Postgresql R2DBC Driver

Language: Java - Size: 3.44 MB - Last synced at: 8 days ago - Pushed at: 6 months ago - Stars: 1,036 - Forks: 184

apple/servicetalk

A networking framework that evolves with your application

Language: Java - Size: 68.1 MB - Last synced at: about 15 hours ago - Pushed at: about 16 hours ago - Stars: 954 - Forks: 185

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: 9 days ago - Pushed at: 10 days ago - Stars: 926 - 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: 11 months ago - Pushed at: almost 2 years ago - Stars: 862 - Forks: 58

smallrye/smallrye-mutiny

An Intuitive Event-Driven Reactive Programming Library for Java

Language: Java - Size: 22.6 MB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 842 - Forks: 133

raquo/Laminar

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

Language: Scala - Size: 9.48 MB - Last synced at: 9 days ago - Pushed at: 13 days ago - Stars: 785 - Forks: 57

leonoel/missionary

A functional effect and streaming system for Clojure/Script

Language: Clojure - Size: 528 KB - Last synced at: 3 days ago - Pushed at: about 2 months ago - Stars: 725 - Forks: 29

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: 9 days ago - Pushed at: almost 2 years ago - Stars: 686 - Forks: 51

mirromutth/r2dbc-mysql 📦

R2DBC MySQL Implementation

Language: Java - Size: 2.08 MB - Last synced at: 5 months ago - Pushed at: over 1 year ago - Stars: 656 - Forks: 98

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.74 MB - Last synced at: 9 days ago - Pushed at: 14 days ago - Stars: 622 - Forks: 107

jetlinks/jetlinks

JetLinks Core

Size: 259 KB - Last synced at: about 16 hours ago - Pushed at: about 18 hours ago - Stars: 500 - Forks: 266

shamansir/rpd

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

Language: JavaScript - Size: 17.7 MB - Last synced at: 3 days ago - Pushed at: almost 5 years 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: 11 months ago - Pushed at: over 1 year ago - Stars: 442 - Forks: 26

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: 11 days ago - Pushed at: 11 days ago - Stars: 431 - Forks: 125

r2dbc/r2dbc-spi

Service Provider Interface for R2DBC Implementations

Language: Java - Size: 762 KB - Last synced at: 9 days ago - Pushed at: 5 months ago - Stars: 426 - Forks: 57

davidmoten/rxjava2-jdbc

RxJava2 integration with JDBC including Non-blocking Connection Pools

Language: Java - Size: 1.41 MB - Last synced at: 7 days ago - Pushed at: 7 days ago - Stars: 393 - Forks: 42

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: about 3 years ago - Stars: 355 - Forks: 51

r2dbc/r2dbc-client 📦

Reactive Relational Database Connectivity

Language: Java - Size: 744 KB - Last synced at: 7 days 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: 12 months ago - Pushed at: about 1 year ago - Stars: 341 - Forks: 635

softwaremill/kmq

Kafka-based message queue

Language: Scala - Size: 451 KB - Last synced at: 13 days ago - Pushed at: 28 days ago - Stars: 337 - Forks: 45

jetlinks/rule-engine

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

Language: Java - Size: 791 KB - Last synced at: 22 days ago - Pushed at: 22 days ago - Stars: 289 - Forks: 172

LoopPerfect/rxterm

Functional reactive terminals in C++ ⚡⌨️

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

raquo/Airstream

State propagation and event streams with mandatory ownership and no glitches

Language: Scala - Size: 1.62 MB - Last synced at: 13 days ago - Pushed at: about 1 month ago - Stars: 254 - Forks: 29

reactor/reactor-addons

Additional optional modules for the Reactor project

Language: Java - Size: 5.95 MB - Last synced at: 11 days ago - Pushed at: 12 days ago - Stars: 237 - Forks: 82

ReactiveX/RxJavaReactiveStreams

Adapter between RxJava and ReactiveStreams

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

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.94 MB - Last synced at: 8 days ago - Pushed at: 8 days ago - Stars: 233 - Forks: 25

CleverCloud/pulsar4s

Idiomatic, typesafe, and reactive Scala client for Apache Pulsar

Language: Scala - Size: 821 KB - Last synced at: 6 months ago - Pushed at: 8 months ago - Stars: 227 - Forks: 45

playframework/play-ws

Standalone Play WS, an async HTTP client with fluent API

Language: Scala - Size: 2.31 MB - Last synced at: about 4 hours ago - Pushed at: 12 days ago - Stars: 225 - Forks: 88

oracle/oracle-r2dbc

R2DBC Driver for Oracle Database

Language: Java - Size: 1.03 MB - Last synced at: 14 days ago - Pushed at: 4 months ago - Stars: 206 - Forks: 43

r2dbc/r2dbc-h2

R2DBC H2 Implementation

Language: Java - Size: 729 KB - Last synced at: 18 days ago - Pushed at: 12 months ago - Stars: 205 - Forks: 46

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: 12 days ago - Pushed at: almost 2 years ago - Stars: 201 - 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: about 2 months ago - Pushed at: about 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: 4 days ago - Pushed at: over 5 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: 12 months 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: 16 days 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: 15 days ago - Pushed at: over 2 years ago - Stars: 171 - Forks: 41

davidmoten/rxjava2-extras

Utilities for use with RxJava 2

Language: Java - Size: 2.16 MB - Last synced at: 9 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: 1 day 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: 22 days ago - Pushed at: almost 2 years ago - Stars: 158 - Forks: 27

r2dbc/r2dbc-proxy

R2DBC Proxying Framework

Language: Java - Size: 6.9 MB - Last synced at: 15 days ago - Pushed at: 10 months ago - Stars: 149 - Forks: 21

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: 3 days ago - Pushed at: 4 days ago - Stars: 128 - Forks: 16

crobox/clickhouse-scala-client

Clickhouse Scala Client with Reactive Streams support

Language: Scala - Size: 1.36 MB - Last synced at: 9 days ago - Pushed at: about 1 month 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: 10 days 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: over 1 year 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.1 MB - Last synced at: 6 days ago - Pushed at: 7 days ago - Stars: 98 - 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: 10 days 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: about 2 years ago - Pushed at: about 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: 17 days 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: 8 months ago - Pushed at: 8 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: 13 days 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: 17 days ago - Pushed at: 9 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: 19 days ago - Pushed at: 10 months ago - Stars: 73 - Forks: 8

jetty-project/jetty-reactive-httpclient

Jetty ReactiveStreams HttpClient

Language: Java - Size: 954 KB - Last synced at: 17 days ago - Pushed at: 19 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: 18 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.19 MB - Last synced at: 5 months ago - Pushed at: 5 months ago - Stars: 68 - Forks: 37

jjeffcaii/reactor-go

A golang implementation for reactive-streams.

Language: Go - Size: 393 KB - Last synced at: 16 days ago - Pushed at: about 1 month ago - Stars: 67 - Forks: 8

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.1 MB - Last synced at: 4 days ago - Pushed at: 7 days ago - Stars: 66 - Forks: 37

idugalic/reactive-company

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

Language: Java - Size: 405 KB - Last synced at: 8 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 year 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: about 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 1 month ago - Pushed at: almost 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: about 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: about 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: 691 KB - Last synced at: 4 days ago - Pushed at: 4 days ago - Stars: 61 - Forks: 19

monix/monix-connect

A set of connectors for Monix. 🔛

Language: Scala - Size: 8.56 MB - Last synced at: 20 days ago - Pushed at: 8 months ago - Stars: 60 - Forks: 17

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

Kafka with KafkaReactor and Kafka Streams Examples in Kotlin

Language: Kotlin - Size: 447 KB - Last synced at: 9 days ago - Pushed at: 4 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: 11 months ago - Pushed at: about 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: 11 days ago - Pushed at: about 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: 22 days ago - Pushed at: 24 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: 17 days ago - Pushed at: about 1 year 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: 18 days ago - Pushed at: about 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: about 2 years ago - Pushed at: about 5 years ago - Stars: 50 - Forks: 38

ReactiveHTML/rimmel

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

Language: TypeScript - Size: 5.25 MB - Last synced at: 4 days ago - Pushed at: 4 days ago - Stars: 48 - Forks: 4

datastax/reactive-pulsar

Reactive Streams adapter for Apache Pulsar Java Client

Language: Java - Size: 268 KB - Last synced at: 16 days 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: almost 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: 4 days ago - Pushed at: 11 months ago - Stars: 47 - Forks: 27

funcool/potok

Reactive streams based state management toolkit for ClojureScript

Language: Clojure - Size: 175 KB - Last synced at: 16 days ago - Pushed at: 4 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: 2 days ago - Pushed at: about 2 years ago - Stars: 45 - Forks: 1

apache/pekko-grpc

Apache Pekko gRPC

Language: Scala - Size: 3.86 MB - Last synced at: 4 days ago - Pushed at: 7 days ago - Stars: 44 - Forks: 20

netifi-proteus/proteus-java 📦

Proteus Java Client

Language: Java - Size: 1.23 MB - Last synced at: 12 months ago - Pushed at: almost 6 years ago - Stars: 43 - Forks: 3