70 Repositories
Java reactive-streams Libraries
Non-Blocking Reactive Foundation for the JVM
Reactor Core Non-Blocking Reactive Streams Foundation for the JVM both implementing a Reactive Extensions inspired API and efficient event streaming s
Vert.x virtual threads incubator
Vert.x Virtual Threads Incubator Incubator for virtual threads based prototypes. Prerequisites Vert.x 4.3.2 Java 19 using preview feature OpenJDK 19 E
A small Reactive API with RxJava for Minecraft Paper Plugins.
RxPaper A small Reactive API with RxJava for Minecraft Paper Plugins. Usage RxPaper.io() When you want to return something back in the Minecraft Threa
Acceso a Datos - 01 Streams, Ficheros y Expresiones Regulares. 2DAM. Curso 2021-2022
Acceso a Datos - 01 Streams, Ficheros y Expresiones Regulares Tema 01 Streams, Ficheros y Expresiones Regulares. 2DAM. Curso 2021/2022. Contenidos TDA
DCL-350: Implementing MicroService Architecture using Spring Cloud
DCL-350: Implementing MicroService Architecture using Spring Cloud
Reference implementation for MINAS (MultI-class learNing Algorithm for data Streams), an algorithm to address novelty detection in data streams multi-class problems.
Reference implementation for MINAS (MultI-class learNing Algorithm for data Streams), an algorithm to address novelty detection in data streams multi-class problems.
KC4Streams - a simple Java library that provides utility classes and standard implementations for most of the Kafka Streams pluggable interfaces
KC4Streams (which stands for Kafka Commons for Streams) is a simple Java library that provides utility classes and standard implementations for most of the Kafka Streams pluggable interfaces.
DCL-204: Java SE 17 Programming
DCL-204: Java SE 17 Programming These projects are created as part of the following training: DCL-204 "Java SE 17 Programming" Please follow the link
Microservices with Spring Boot and Kafka Demo Project
Example microservices showing how to use Kafka and Kafka Streams with Spring Boot on the example of distributed transactions implementations with the SAGA pattern
Quarkus: Supersonic Subatomic Java.
Quarkus - Supersonic Subatomic Java Quarkus is a Cloud Native, (Linux) Container First framework for writing Java applications. Container First: Minim
Efficient reliable UDP unicast, UDP multicast, and IPC message transport
Aeron Efficient reliable UDP unicast, UDP multicast, and IPC message transport. Java and C++ clients are available in this repository, and a .NET clie
Reactive Streams Specification for the JVM
Reactive Streams The purpose of Reactive Streams is to provide a standard for asynchronous stream processing with non-blocking backpressure. The lates
RSocket is a binary protocol for use on byte stream transports such as TCP, WebSockets, and Aeron
RSocket RSocket is a binary protocol for use on byte stream transports such as TCP, WebSockets, and Aeron. It enables the following symmetric interact
Java & Kotlin Async DataBase Driver for MySQL and PostgreSQL written in Kotlin
jasync-sql is a Simple, Netty based, asynchronous, performant and reliable database drivers for PostgreSQL and MySQL written in Kotlin. Show your ❤ wi
A template and introduction for the first kafka stream application. The readme file contains all the required commands to run the Kafka cluster from Scrach
Kafka Streams Template Maven Project This project will be used to create the followings: A Kafka Producer Application that will start producing random
Akka gRPC - Support for building streaming gRPC servers and clients on top of Akka Streams.
akka-grpc Support for building streaming gRPC servers and clients on top of Akka Streams. This library is meant to be used as a building block in proj
A joint research effort for building highly optimized Reactive-Streams compliant operators.
reactive-streams-commons A joint research effort for building highly optimized Reactive-Streams compliant operators. Current implementors include RxJa
Standalone Play WS, an async HTTP client with fluent API
Play WS Standalone Play WS is a powerful HTTP Client library, originally developed by the Play team for use with Play Framework. It uses AsyncHttpClie
Beagle helps you identify keywords, phrases, regexes, and complex search queries of interest in streams of text documents.
Beagle Beagle is a detector of interesting things in text. Its intended use is in-stream search applications. Suppose you need to monitor a stream of
A server-state reactive Java web framework for building real-time user interfaces and UI components.
RSP About Maven Code examples HTTP requests routing HTML markup Java DSL Page state model Single-page application Navigation bar URL path UI Component
Querystream - Build JPA Criteria queries using a Stream-like API
QueryStream QueryStream allows you to perform JPA queries using a Stream-like API. Just like a Java 8 Stream, a QueryStream is built up in a pipeline,
Dcl204-2020-dec-27 - DCL-204: Java SE 17 Programming
DCL-204: Java SE 17 Programming These projects are created as part of the following training: DCL-204 "Java SE 17 Programming" Please follow the link
Spring 5 Reactive playground
Spring Reactive Sample This is a sandbox project for demonstrating Reactive Streams support in Spring framework and Spring ecosystem. I've also mainta
Decorating Spring Boot Reactive WebClient for tracing the request and response data for http calls.
SpringBoot Reactive WebClient 🔍 Tracing HTTP Request through a single pane of glass Decorating Spring Boot Reactive WebClient for tracing the request
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
reactive-iot-backend The is the source code of the live coding demo for "Building resilient and scalable API backends with Apache Pulsar and Spring Re
SpringBoot show case application for reactive-pulsar library (Reactive Streams adapter for Apache Pulsar Java Client)
Reactive Pulsar Client show case application Prerequisites Cloning reactive-pulsar Running this application requires cloning https://github.com/lhotar
A practical example to showcase Redis Streams and RediSearch in action
Redis Streams in Action A practical example to showcase Redis Streams in action. The goal is to process Twitter data in real-time for search and query
Apache rocketmq
RocketMQ Streams Features 轻量级部署：可以单独部署，也支持集群部署 多种类型的数据输入以及输出，source支持 rocketmq ， sink支持db, rocketmq 等 DataStream Example import org.apache.rocketmq.st
Zero-dependency Reactive Streams publishers library
⚡️ Mutiny Zero: a zero-dependency Reactive Streams publishers library for Java Mutiny Zero is a minimal API for creating reactive-streams compliant pu
Consume an async api (with callback) from sync endpoint using vert.x
vertx-async-to-sync Problem statement Suppose we have two services - A and B. In a trivial and everyday scenario, client makes request to A. A then do
End to End project for Kafka Streams using Spring Cloud Kafka streams
Spring Kafka Streams using Spring Cloud Streams End to End example Endpoint http://localhost:8080/domain/lookup/facebook - to pull all facebook relate
Discord4J is a fast, powerful, unopinionated, reactive library to enable quick and easy development of Discord bots for Java, Kotlin, and other JVM languages using the official Discord Bot API.
Discord4J is a fast, powerful, unopinionated, reactive library to enable quick and easy development of Discord bots for Java, Kotlin, and other JVM languages using the official Discord Bot API.
A reactive dataflow engine, a data stream processing framework using Vert.x
🐝 NeonBee Core NeonBee is an open source reactive dataflow engine, a data stream processing framework using Vert.x. Description NeonBee abstracts mos
Amazing Ruby's "Enumerable" ported to Java
Overview How to use? .all .any .none .select .map .count .reject .find How to contribute? Contributors Overview enumerable4j is a Ruby's well known En
Modern Java - A Guide to Java 8
Modern Java - A Guide to Java 8 This article was originally posted on my blog. You should also read my Java 11 Tutorial (including new language and AP
Functional Reactive Programming (FRP) for JavaFX
ReduxFX Functional Reactive Programming (FRP) for JavaFX ReduxFX in 1 minute ReduxFX is a set of libraries that enable you to use functional reactive
Reactive event streams, observable values and more for JavaFX.
ReactFX ReactFX is an exploration of (functional) reactive programming techniques for JavaFX. These techniques usually result in more concise code, le
Reactive JavaFX Event Handling
ReactorFX This lightweight convenience library allows for simple integration between Project Reactor and JavaFX. ReactorFX provides fluent factories t
Rapidoid - Extremely Fast, Simple and Powerful Java Web Framework and HTTP Server!
Rapidoid - Simple. Powerful. Secure. Fast! Rapidoid is an extremely fast HTTP server and modern Java web framework / application container, with a str
SAMOA (Scalable Advanced Massive Online Analysis) is an open-source platform for mining big data streams.
SAMOA: Scalable Advanced Massive Online Analysis. This repository is discontinued. The development of SAMOA has moved over to the Apache Software Foun
Machine Learning Platform and Recommendation Engine built on Kubernetes
Update January 2018 Seldon Core open sourced. Seldon Core focuses purely on deploying a wide range of ML models on Kubernetes, allowing complex runtim
Reactive stubs for gRPC
What is reactive-grpc? Reactive gRPC is a suite of libraries for using gRPC with Reactive Streams programming libraries. Using a protocol buffers comp
Proteus Java Client
Netifi Proteus Java This project has been moved to https://github.com/netifi/netifi-java Build from Source Run the following Gradle command to build t
Your go-to microservice framework for any situation, from the creator of Netty et al. You can build any type of microservice leveraging your favorite technologies, including gRPC, Thrift, Kotlin, Retrofit, Reactive Streams, Spring Boot and Dropwizard.
Visit the official web site for more information. Armeria Build a reactive microservice at your pace, not theirs. Armeria is your go-to microservice f
Efficient reliable UDP unicast, UDP multicast, and IPC message transport
Aeron Efficient reliable UDP unicast, UDP multicast, and IPC message transport. Java and C++ clients are available in this repository, and a .NET clie
RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM.
RxJava: Reactive Extensions for the JVM RxJava is a Java VM implementation of Reactive Extensions: a library for composing asynchronous and event-base
Reactive Streams Utilities - Future standard utilities library for Reactive Streams.
Reactive Streams Utilities This is an exploration of what a utilities library for Reactive Streams in the JDK might look like. Glossary: A short gloss
Immutable in-memory R-tree and R*-tree implementations in Java with reactive api
rtree In-memory immutable 2D R-tree implementation in java using RxJava Observables for reactive processing of search results. Status: released to Mav
jOOλ - The Missing Parts in Java 8 jOOλ improves the JDK libraries in areas where the Expert Group's focus was elsewhere. It adds tuple support, function support, and a lot of additional functionality around sequential Streams. The JDK 8's main efforts (default methods, lambdas, and the Stream API) were focused around maintaining backwards compatibility and implementing a functional API for parallelism.
jOOλ jOOλ is part of the jOOQ series (along with jOOQ, jOOX, jOOR, jOOU) providing some useful extensions to Java 8 lambdas. It contains these classes
An advanced, but easy to use, platform for writing functional applications in Java 8.
Getting Cyclops X (10) The latest version is cyclops:10.4.0 Stackoverflow tag cyclops-react Documentation (work in progress for Cyclops X) Integration
Reactive Programming for Android
Reactive Programming for Android Agera is a set of classes and interfaces to help write functional, asynchronous, and reactive applications for Androi
jdbi is designed to provide convenient tabular data access in Java; including templated SQL, parameterized and strongly typed queries, and Streams integration
The Jdbi library provides convenient, idiomatic access to relational databases in Java. Jdbi is built on top of JDBC. If your database has a JDBC driv
OrientDB is the most versatile DBMS supporting Graph, Document, Reactive, Full-Text, Geospatial and Key-Value models in one Multi-Model product. OrientDB can run distributed (Multi-Master), supports SQL, ACID Transactions, Full-Text indexing and Reactive Queries. OrientDB Community Edition is Open Source using a liberal Apache 2 license.
OrientDB | Develop branch: | 2.2.x branch: | Chat with the community: What is OrientDB? OrientDB is an Open Source Multi-Model NoSQL DBMS with the sup
Orbit - Virtual actor framework for building distributed systems
Full Documentation See the documentation website for full documentation, examples and other information. Orbit 1 Looking for Orbit 1? Visit the orbit1
Reactive Microservices for the JVM
Lagom - The Reactive Microservices Framework Lagom is a Swedish word meaning just right, sufficient. Microservices are about creating services that ar
Vert.x is a tool-kit for building reactive applications on the JVM
Vert.x Core This is the repository for Vert.x core. Vert.x core contains fairly low-level functionality, including support for HTTP, TCP, file system
Build highly concurrent, distributed, and resilient message-driven applications on the JVM
Akka We believe that writing correct concurrent & distributed, resilient and elastic applications is too hard. Most of the time it's because we are us
A networking framework that evolves with your application
ServiceTalk ServiceTalk is a JVM network application framework with APIs tailored to specific protocols (e.g. HTTP/1.x, HTTP/2.x, etc…) and supports m
Modern Java - A Guide to Java 8
Modern Java - A Guide to Java 8 This article was originally posted on my blog. You should also read my Java 11 Tutorial (including new language and AP
Efficient reliable UDP unicast, UDP multicast, and IPC message transport
Aeron Efficient reliable UDP unicast, UDP multicast, and IPC message transport. Java and C++ clients are available in this repository, and a .NET clie
The Java microservice lib. QBit is a reactive programming lib for building microservices - JSON, HTTP, WebSocket, and REST. QBit uses reactive programming to build elastic REST, and WebSockets based cloud friendly, web services. SOA evolved for mobile and cloud. ServiceDiscovery, Health, reactive StatService, events, Java idiomatic reactive programming for Microservices.
QBit Java Micorservices lib tutorials| QBit Website | QBit uses Reakt | QBit works with Vert.x | Reakt Vertx QBit - The Microservice Lib for Java - JS
Your go-to microservice framework for any situation, from the creator of Netty et al. You can build any type of microservice leveraging your favorite technologies, including gRPC, Thrift, Kotlin, Retrofit, Reactive Streams, Spring Boot and Dropwizard.
Visit the official web site for more information. Armeria Build a reactive microservice at your pace, not theirs. Armeria is your go-to microservice f
Firefly is an asynchronous web framework for rapid development of high-performance web application.
What is Firefly? Firefly framework is an asynchronous Java web framework. It helps you create a web application Easy and Quickly. It provides asynchro
Play Framework
Play Framework - The High Velocity Web Framework The Play Framework combines productivity and performance making it easy to build scalable web applica
⚗️ Lightweight HTTP extensions for Java 11
Methanol A lightweight library that complements java.net.http for a better HTTP experience. Overview Methanol provides useful lightweight HTTP extensi
Enhancing Java Stream API
StreamEx 0.7.3 Enhancing Java Stream API. This library defines four classes: StreamEx, IntStreamEx, LongStreamEx, DoubleStreamEx which are fully compa
jOOλ - The Missing Parts in Java 8 jOOλ improves the JDK libraries in areas where the Expert Group's focus was elsewhere. It adds tuple support, function support, and a lot of additional functionality around sequential Streams. The JDK 8's main efforts (default methods, lambdas, and the Stream API) were focused around maintaining backwards compatibility and implementing a functional API for parallelism.
jOOλ jOOλ is part of the jOOQ series (along with jOOQ, jOOX, jOOR, jOOU) providing some useful extensions to Java 8 lambdas. It contains these classes
An advanced, but easy to use, platform for writing functional applications in Java 8.
Getting Cyclops X (10) The latest version is cyclops:10.4.0 Stackoverflow tag cyclops-react Documentation (work in progress for Cyclops X) Integration
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. its open and designed to accommodate changes. (no sidecar in a form of broker or any kind)
scalecube-services MICROSERVICES 2.0 An open-source project that is focused on streamlining reactive-programming of Microservices Reactive-systems tha
A reactive Java framework for building fault-tolerant distributed systems
Atomix Website | Javadoc | Slack | Google Group A reactive Java framework for building fault-tolerant distributed systems Please see the website for f