Ecosyste.ms: Repos

An open API service providing repository metadata for many open source software ecosystems.

GitHub topics: project-reactor

Repositories

pellse/assembler

Assembler is a reactive data aggregation framework for querying and merging data from multiple data sources/services. CohereFlux 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: 3.89 MB - Last synced: about 15 hours ago - Pushed: about 23 hours ago - Stars: 121 - Forks: 17

Ahoo-Wang/CoSec

RBAC-based And Policy-based Multi-Tenant Reactive Security Framework | 基于 RBAC 和策略的多租户响应式安全框架

Language: Kotlin - Size: 5.97 MB - Last synced: 7 days ago - Pushed: 7 days ago - Stars: 25 - Forks: 3

anticipasean/funcify-feature-eng

Create a GraphQL feature engineering pipeline that draws from data element sources and transforms using transformer sources

Language: Kotlin - Size: 4.96 MB - Last synced: 7 days ago - Pushed: 7 days ago - Stars: 0 - Forks: 0

apache/pulsar-client-reactive

Reactive client for Apache Pulsar

Language: Java - Size: 595 KB - Last synced: 8 days ago - Pushed: 11 days ago - Stars: 55 - Forks: 16

spring-attic/reactor-scala-extensions 📦

A scala extension for Project Reactor's Flux and Mono

Language: Scala - Size: 2.62 MB - Last synced: 8 days ago - Pushed: about 2 years ago - Stars: 52 - Forks: 15

smoothbear/webflux-example

A webflux example

Language: Kotlin - Size: 78.1 KB - Last synced: 8 days ago - Pushed: almost 3 years ago - Stars: 2 - Forks: 0

AxonFramework/extension-reactor

Axon Framework extension for integration with Project Reactor, allowing an extended reactive API.

Language: Java - Size: 694 KB - Last synced: 10 days ago - Pushed: 10 days ago - Stars: 26 - Forks: 6

anticipasean/funcify

Explore functional DSLs and type systems in Java and Kotlin that facilitate easier-to-read, cleaner, more testable, and more fault tolerant code

Language: Java - Size: 622 KB - Last synced: 11 days ago - Pushed: over 2 years ago - Stars: 0 - Forks: 0

dvillavicencio/riven-bot

Discord Bot for Destiny 2 that retrieves statistics regarding Raid and Dungeon activities through Discord chat

Language: Java - Size: 50.6 MB - Last synced: 8 days ago - Pushed: 8 days ago - Stars: 2 - Forks: 0

lexyu-spring-projects-collection/spring-boot-reactive-programming-collection

Language: Java - Size: 158 KB - Last synced: 20 days ago - Pushed: 4 months ago - Stars: 1 - Forks: 0

schananas/practical-reactor

Practical Project Reactor and reactive programing workshop

Language: Java - Size: 1.69 MB - Last synced: 20 days ago - Pushed: 3 months ago - Stars: 341 - Forks: 635

ferfujikawa/reactive-spring

Demo project from Build Reactive MicroServices using Spring WebFlux/SpringBoot course

Language: Java - Size: 141 KB - Last synced: 26 days ago - Pushed: 26 days ago - Stars: 0 - Forks: 0

NirmalSilwal/reactive-programming-for-beginners

Reactive programming (Project Reactor) - Flux and Mono practice

Language: Java - Size: 16.6 KB - Last synced: 27 days ago - Pushed: about 1 year ago - Stars: 0 - Forks: 0

Ali-Hassan33/Reactive-Chat-Application

Build a reactive chat application using Project Reactor, Spring Boot, and Vaadin, enabling real-time private messaging among users.

Language: Java - Size: 2.42 MB - Last synced: 28 days ago - Pushed: 29 days ago - Stars: 1 - Forks: 0

danielcifuentes54/spring-boot-reactive-client

Client built with reactive programming (project reactor) for consuming the project spring-boot-reactive-api

Language: Java - Size: 56.6 KB - Last synced: about 1 month ago - Pushed: about 4 years ago - Stars: 0 - Forks: 0

danielcifuentes54/spring-boot-reactive-api

API con programación reactiva - projectreactor - Functional End Points - Eureka Client

Language: Java - Size: 63.5 KB - Last synced: about 1 month ago - Pushed: about 4 years ago - Stars: 0 - Forks: 0

Andrea-Cavallo/Twitch-SpringBoot-Neo4j

SpringBoot ( Webflux ) ( project Reaktor - Using NoSQl db Neo4j )

Language: Java - Size: 147 KB - Last synced: about 1 month ago - Pushed: over 1 year ago - Stars: 1 - Forks: 0

matheusmv/project-reactor-studies

Studying Reactive Programming Concepts with Java

Language: Java - Size: 24.4 KB - Last synced: about 1 month ago - Pushed: over 2 years ago - Stars: 0 - Forks: 0

bmd007/reactiveland

Learn about reactive programming and reactive systems

Language: Java - Size: 12.6 MB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 1 - Forks: 1

SandroHc/reactive-jikan

Java wrapper for the Jikan API V4 - an unofficial MyAnimeList API - with the power of Project Reactor and reactive streams. ⚡ — https://jikan.moe

Language: Java - Size: 1.25 MB - Last synced: about 1 month ago - Pushed: over 1 year ago - Stars: 23 - Forks: 4

GroupHQ/group-service

Spring Boot application providing functionality for managing and interacting with groups

Language: Java - Size: 479 KB - Last synced: about 1 month ago - Pushed: 2 months ago - Stars: 0 - Forks: 0

lhotari/reactive-iot-backend-ApacheCon2021

source code of the live coding demo for "Building resilient and scalable API backends with Apache Pulsar and Spring Reactive" talk held at ApacheCon@Home 2021

Language: Java - Size: 562 KB - Last synced: about 1 month ago - Pushed: 5 months ago - Stars: 4 - Forks: 2

repos-hb/project-reactor-workshop2

https://www.youtube.com/playlist?list=PL0Un1HNdB4jFCsHsQg2HOfO03XfECuMiw

Language: Java - Size: 22.5 KB - Last synced: about 1 month ago - Pushed: about 2 months ago - Stars: 0 - Forks: 0

MasterCloudApps-Projects/AsyncReactiveProgramming

This repository is intended to be a compilation of presentations, examples, links, and other resources on asynchronous and reactive programming in Java

Size: 7.59 MB - Last synced: 29 days ago - Pushed: over 3 years ago - Stars: 27 - Forks: 5

camunda-community-hub/camunda-platform-7-reactor 📦

Event Driven process applications

Language: Java - Size: 701 KB - Last synced: 27 days ago - Pushed: about 2 years ago - Stars: 80 - Forks: 34

eh3rrera/project-reactor-course

A guide to learn reactive programming with Project Reactor

Language: Java - Size: 5.59 MB - Last synced: about 1 month ago - Pushed: 2 months ago - Stars: 13 - Forks: 4

justJavaProgrammer/grpc-crud

A simple GRPC CRUD application using Reactor

Language: Java - Size: 146 KB - Last synced: about 2 months ago - Pushed: about 2 months ago - Stars: 0 - Forks: 0

rucko24/poc-sync-async

Poc for processing iterations, with synchronous and asynchronous random data.

Language: JavaScript - Size: 9.25 MB - Last synced: 2 months ago - Pushed: 6 months ago - Stars: 0 - Forks: 0

GroupHQ/group-sync

Provides synchronization support between Group Service and end-users

Language: Java - Size: 346 KB - Last synced: about 1 month ago - Pushed: 2 months ago - Stars: 0 - Forks: 0

gregwhitaker/sqs-priority-client

Reactive wrapper around the Amazon SQS client that allows reading from multiple queues with weighted priority.

Language: Java - Size: 594 KB - Last synced: 2 months ago - Pushed: about 3 years ago - Stars: 3 - Forks: 0

gregwhitaker/springwebflux-websockets-example

Example of a reactive application using Websockets and Spring WebFlux

Language: Java - Size: 103 KB - Last synced: 2 months ago - Pushed: over 3 years ago - Stars: 0 - Forks: 2

gregwhitaker/rsocket-replayprocessor-example

Example of storing and replaying messages when a subscriber connects with Reactor and RSocket

Language: Java - Size: 74.2 KB - Last synced: 2 months ago - Pushed: over 3 years ago - Stars: 0 - Forks: 0

gregwhitaker/reactor-replayprocessor-example

Example of Replaying Historical Events with Project Reactor ReplayProcessor

Language: Java - Size: 77.1 KB - Last synced: 2 months ago - Pushed: over 3 years ago - Stars: 0 - Forks: 0

gregwhitaker/dynamo-scan

Library for scanning records in AWS DynamoDB tables.

Language: Java - Size: 80.1 KB - Last synced: 2 months ago - Pushed: about 3 years ago - Stars: 0 - Forks: 0

netifi/reactive-pacman Fork of CollaborationInEncapsulation/reactive-pacman

Multiplayer Pac-Man game made in 1 week using Phaser and RSocket

Language: TypeScript - Size: 2.52 MB - Last synced: about 1 month ago - Pushed: about 5 years ago - Stars: 27 - Forks: 3

Cristian-Sknz/minecraft-party

A party game plugin for Minecraft inspired by Hypixel Party (Incomplete)

Language: Kotlin - Size: 283 KB - Last synced: 4 months ago - Pushed: 4 months ago - Stars: 0 - Forks: 0

odrianoaliveira/spring-stream-reactive-blocking_vs_nonblocking

learning reactive stream and comparing the behavior between a blocking call not wrapped with Mono.fromCallable vs wrapped.

Language: Java - Size: 45.9 KB - Last synced: 4 months ago - Pushed: almost 6 years ago - Stars: 2 - Forks: 0

delta-leonis/zosma

center of our universe

Language: Java - Size: 1.47 MB - Last synced: 4 months ago - Pushed: almost 6 years ago - Stars: 3 - Forks: 1

VinncentWong/Sipas-BE

Sipas backend implementation written in Spring Webflux + Netty + Project Reactor with R2DBC

Language: Java - Size: 347 KB - Last synced: 4 months ago - Pushed: 6 months ago - Stars: 0 - Forks: 0

DipakSalunke/micronaut-basics

micronaut framework with API, kafka, kafka-streams and reactive

Language: Java - Size: 27.3 KB - Last synced: 4 months ago - Pushed: 4 months ago - Stars: 0 - Forks: 0

datastax/reactive-pulsar

Reactive Streams adapter for Apache Pulsar Java Client

Language: Java - Size: 268 KB - Last synced: 19 days ago - Pushed: about 1 year ago - Stars: 47 - Forks: 15

mihaildemidoff/reactive-tg-bots

Telegram bots java client written in project reactor

Language: Java - Size: 289 KB - Last synced: 5 months ago - Pushed: 6 months ago - Stars: 0 - Forks: 0

lhotari/reactive-pulsar-showcase

SpringBoot show case application for pulsar-client-reactive library (Reactive Client for Apache Pulsar)

Language: Java - Size: 213 KB - Last synced: about 1 month ago - Pushed: 6 months ago - Stars: 11 - Forks: 5

rucko24/nodemcu-with-flow

Basic example of data collection, using the ESP8285 with the dht22 sensor, where the relative humidity and temperature are plotted with respect to time in real time chart and consuming endpoints reactively with Scheduled WebClient.

Language: Java - Size: 717 KB - Last synced: 2 months ago - Pushed: about 2 years ago - Stars: 1 - Forks: 0

fResult/Task-MGMT

My Reactive Programming learning using Spring Boot Webflux, and Kotlin.

Language: Kotlin - Size: 141 KB - Last synced: 4 months ago - Pushed: 5 months ago - Stars: 0 - Forks: 1

nakiviar/spring-reactor-demo

Language: Java - Size: 77.1 KB - Last synced: 6 months ago - Pushed: 6 months ago - Stars: 0 - Forks: 0

vasudeva78/spring-oracle-reactive

Spring Boot Reactive Relational Database Connectivity(R2DBC) to Oracle

Language: Java - Size: 20.5 KB - Last synced: 8 months ago - Pushed: almost 2 years ago - Stars: 1 - Forks: 0

JavaSaBr/mqtt-broker

Java implementation of MQTT 5.0 compatible broker based on RLib library.

Language: Java - Size: 713 KB - Last synced: 2 months ago - Pushed: over 1 year ago - Stars: 5 - Forks: 1

philsttr/avoiding-reactor-meltdown

Demo for the Avoiding Reactor Meltdown Talk

Language: Java - Size: 73.2 KB - Last synced: 2 months ago - Pushed: about 4 years ago - Stars: 41 - Forks: 17

chenggangpro/reactive-lock

Reactive Lock Based On SpringBoot and simple Reactive-Redis-Distributed-Lock

Language: Java - Size: 8.89 MB - Last synced: about 1 month ago - Pushed: almost 2 years ago - Stars: 14 - Forks: 9

jdvr/lite-rx-api-hands-on Fork of reactor/lite-rx-api-hands-on

Lite Rx API Hands-On with Reactor Core 3

Language: Java - Size: 198 KB - Last synced: 9 months ago - Pushed: over 7 years ago - Stars: 0 - Forks: 0

sandjelkovic/reactive-blog

Test playground for Reactive streams and Spring WebFlux

Language: Kotlin - Size: 54.7 KB - Last synced: 9 months ago - Pushed: over 6 years ago - Stars: 0 - Forks: 0

pwittchen/java-flow-experiments

Experimenting with Reactive Streams in Java 8 and Java 9. This repository is prepared for my talk "Get ready for java.util.concurrent.Flow!" at JDD 2017 Conference in Kraków, Poland

Language: Java - Size: 224 KB - Last synced: 10 months ago - Pushed: over 6 years ago - Stars: 2 - Forks: 2

VitorUssami/studies-spring-webflux

[Studies] spring-webflux | project reactor

Language: Java - Size: 425 KB - Last synced: 10 months ago - Pushed: over 1 year ago - Stars: 2 - Forks: 0

alexismanin/concurrency-examples-kt

Provide both Kotlinx coroutine and Reactor version for examples of this article: https://mccue.dev/pages/5-2-22-go-concurrency-in-java

Language: Kotlin - Size: 103 KB - Last synced: 10 months ago - Pushed: almost 2 years ago - Stars: 1 - Forks: 0

schneidersteve/buckpal-java

Java Example Implementation of a Hexagonal/Onion/Clean Architecture

Language: Java - Size: 176 KB - Last synced: 10 months ago - Pushed: about 1 year ago - Stars: 1 - Forks: 0

wisskirchenj/account-reactive

Reactive Spring Webflux backend with functional usage to implement a simple account service

Language: Java - Size: 296 KB - Last synced: about 1 month ago - Pushed: about 1 month ago - Stars: 0 - Forks: 2

RomaKudryavtsev/java-rombot

Reactive WhatsApp message sending tool

Language: Java - Size: 179 KB - Last synced: 10 months ago - Pushed: 10 months ago - Stars: 0 - Forks: 0

Edson-Mendes/schedule-api

REST API for schedule management

Language: Java - Size: 155 KB - Last synced: 12 months ago - Pushed: 12 months ago - Stars: 0 - Forks: 0

memoria-io/archived-reactive 📦

Reactive Java Utilities (Project Reactor, Netty, Vavr)

Language: Java - Size: 1.78 MB - Last synced: 12 months ago - Pushed: over 1 year ago - Stars: 0 - Forks: 1

mihaildemidoff/itpoker

Planning poker bot

Language: Java - Size: 254 KB - Last synced: about 1 year ago - Pushed: about 1 year ago - Stars: 0 - Forks: 0

kubepay/webflux-again

My Endeavour with Spring5 and others

Language: Java - Size: 1.71 MB - Last synced: 2 months ago - Pushed: over 6 years ago - Stars: 1 - Forks: 0

shadskii/ReactorFX

Reactive JavaFX Event Handling

Language: Java - Size: 218 KB - Last synced: 4 months ago - Pushed: over 4 years ago - Stars: 34 - Forks: 7

SundayBun/kafka_producer

Rest service to send messages to kafka topic

Language: Kotlin - Size: 12.7 KB - Last synced: 11 months ago - Pushed: about 1 year ago - Stars: 0 - Forks: 0

SundayBun/kafka_react_service

Reactive kafka service

Language: Java - Size: 21.5 KB - Last synced: 11 months ago - Pushed: about 1 year ago - Stars: 0 - Forks: 0

gregwhitaker/rsocket-backpressure-example

Example of using Backpressure with RSocket

Language: Java - Size: 68.4 KB - Last synced: 2 months ago - Pushed: over 3 years ago - Stars: 4 - Forks: 2

felipegutierrez/bidding-system-java

This is a bidding system implemented using Java 11 with Spring-webflux and the project-reactor. The project uses spring-actuator and micrometer to expose metrics to Prometheus and visualize them in Grafana. Prometheus alertmanager, nodeexporter, and blackbox are also configured with multiple rules w.r.t. the service and the host system.

Language: Java - Size: 462 KB - Last synced: about 1 year ago - Pushed: almost 3 years ago - Stars: 0 - Forks: 0