Reactive Streams over network boundary - RSocket based RPC with Reactor & RxJava2 bindings, and pluggable serialization (json, cbor, protobuf and othe...
Fast jvm-only implementation of the reactive streams for fs2.
Lightweight and lowkey reactive programming, json handling and webserving for Kotlin.
JMS in the terms of Reactive Streams
A Recursive Web crawler built with Java 8, reactive streams, async queues and AWS DynamoDB.
Kotlin/Angular Realtime Stock Monitor
Example of using R2DBC for Database Access with RSocket and Netifi
Functional reactive microservices for the JVM. Uses Observables for composing event streams.
Akka Reactive Streaming for Azure Event Hubs
Example of sending RSocket Setup Payload with Spring Boot
Azure IoT connector to feed connected devices telemetry to Apache Cassandra
Reactive akka ZooKeeper client
Example data processing pipeline with Akka Streams and Alpakka
Extensions to make SerialPort reactive
A collection of learning resources for topics related to reactive programming
Spring-Boot Microservices Reactive Application with MongoDB and Docker container
Official Android SDK for SaaSquatch. REST API wrapper and widgets in Android WebViews
Small WMS (warehouse management system)
Reactive Downloader Library for Android ( Kotlin )
Chat server built with RSocket and MongoDB change streams
Example projects building Reactive Integrations using Apache Pekko Connectors
A stream-oriented messagebus for modular reactive applications
Reactive State and Async Workflow Management Library for Angular
⚡️ Reactive signals MultiPlatform for Kotlin
EPCIS 2.0 Testdata Generator
Convert GS1 EPCIS events from JSON-LD to XML format and vice versa.
Tools for building function graphs
Learning Reactive development with Spring boot 2 webflux, from Zero to Hero
Reactively streaming SEG-Y parser
Example of using the request-stream interaction model with Netifi and RSocket
Reactivity is an agile tool that allows you to manage the activity that matters in a free, 100% OSS and reactive web application.
NO LONGER MAINTAINED! Atomics, Futures, and Reactive-Streams for Swift
Straightforward rxjava wrapper for scala
Laplace is a Discord bot which collects statistics about a server and its users.
Example of using RSocket Metadata Push in Spring Boot
Example of using RSocket with Spring WebFlux
Spring Boot Reactive Cassandra Kotlin
Consuming Gnip streaming API using Akka HTTP / Streams 2.4.2
Reactive Oanda API wrapper for Scala based on akka-streams and akka-http.
A flutter project to run speech recognition service in background.
small demo of Java9 reactive stream
Experiments with funcool/potok and tonsky/rum. Reactive streams FTW!
Scala wrapper for reactor-core
Flutter weather app written using Reactive way.
The VLINGO XOOM SYMBIO implementation for JDBC for Reactive storage using Event-Sourcing, Key-Value, and Object storage.
A prototype of reactor in Rust.
A reactive driver for chronicle-queue