reactive-streams

git log as an observable stream of JSON

A Recursive Web crawler built with Java 8, reactive streams, async queues and AWS DynamoDB.

A lightweight, zero-dependency reactive programming library for Swift built natively on Swift Concurrency (AsyncStream, Task, Sendable).

Kotlin/Angular Realtime Stock Monitor

Lightweight and lowkey reactive programming, json handling and webserving for Kotlin.

JMS in the terms of Reactive Streams

Fast jvm-only implementation of the reactive streams for fs2.

Reactive Streams over network boundary - RSocket based RPC with Reactor & RxJava2 bindings, and pluggable serialization (json, cbor, protobuf and othe...

Reactive Access to MongoDB in Scala and Java

Extensions to make SerialPort reactive

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

Functional reactive microservices for the JVM. Uses Observables for composing event streams.

Example data processing pipeline with Akka Streams and Alpakka

A collection of learning resources for topics related to reactive programming

Spring-Boot Microservices Reactive Application with MongoDB and Docker container

⚡️ Reactive signals MultiPlatform for Kotlin

Generate valid EPCIS 2.0 and CBV 2.0 test events in JSON/JSON-LD or XML; GS1 Digital Link and EPC URIs, randomized serials and timestamps, event hash...

Example of using R2DBC for Database Access with RSocket and Netifi

Small WMS (warehouse management system)

Official Android SDK for SaaSquatch. REST API wrapper and widgets in Android WebViews

A messagebus-driven module/plugin manager for modular, stream-oriented reactive applications

Reactive State and Async Workflow Management Library for Angular

Reactively streaming SEG-Y parser

Chat server built with RSocket and MongoDB change streams

Example of using the request-stream interaction model with Netifi and RSocket

Learning Reactive development with Spring boot 2 webflux, from Zero to Hero

Reactive Downloader Library for Android ( Kotlin )

Tools for building function graphs

Reactivity is an agile tool that allows you to manage the activity that matters in a free, 100% OSS and reactive web application.

Example of using RSocket with Spring WebFlux

NO LONGER MAINTAINED! Atomics, Futures, and Reactive-Streams for Swift

Example projects building Reactive Integrations using Apache Pekko Connectors

Straightforward rxjava wrapper for scala

Spring Boot Reactive Cassandra Kotlin

Convert GS1 EPCIS 2.0 documents between XML and JSON/JSON-LD, and upgrade EPCIS 1.2 XML to 2.0. Streaming conversion for large event documents, availa...

Reactive Oanda API wrapper for Scala based on akka-streams and akka-http.

Example of using RSocket Metadata Push in Spring Boot

Laplace is a Discord bot which collects statistics about a server and its users.

Consuming Gnip streaming API using Akka HTTP / Streams 2.4.2

Mysql X DevApi wrapped with Spring Reactor

Example Code for Netifi Spring Boot Screencast

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

A prototype of reactor in Rust.

Experiments with funcool/potok and tonsky/rum. Reactive streams FTW!

Shared documents for Reactive Systems Hamburg