reactive-streams

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

Azure IoT connector to feed connected devices telemetry to Apache Cassandra

Tools for building function graphs

Reactive akka ZooKeeper client

Example of using RSocket with Spring WebFlux

Spring Boot Reactive Cassandra Kotlin

Example data processing pipeline with Akka Streams and Alpakka

Spring-Boot Microservices Reactive Application with MongoDB and Docker container

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

Small WMS (warehouse management system)

Reactive Downloader Library for Android ( Kotlin )

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

Example of using RSocket Metadata Push in Spring Boot

A collection of learning resources for topics related to reactive programming

Consuming Gnip streaming API using Akka HTTP / Streams 2.4.2

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

Straightforward rxjava wrapper for scala

Atomics, Futures, and Reactive-Streams for Swift

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 the request-stream interaction model with Netifi and RSocket

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

A reactive driver for chronicle-queue

Micronaut playground

Reactively streaming SEG-Y parser

Mysql X DevApi wrapped with Spring Reactor

Spring 5 exercices

Ember Cerebral

Shared documents for Reactive Systems Hamburg

Kotlin/Angular Realtime Stock Monitor

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

Example Code for Netifi Spring Boot Screencast

small demo of Java9 reactive stream

Scala wrapper for reactor-core

Flutter weather app written using Reactive way.

Telegram bot built with reactive streams

A prototype of reactor in Rust.

Reactive Extensions for async Rust

Java reactive streams workshop: basic implementations of Publisher, Subscriber, Subscription and Processor.

Example of using Backpressure with RSocket

Chat server built with RSocket and MongoDB change streams

A single repository to learn the basics of Android in Java without all the fluff.

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...

Android application for searching for GitHub repositories

Reducing Microservice Complexity with Kafka and Reactive Streams

Code to experiment with Project Loom continuation/fiber API.

Streaming cats

Simple POC of nonblocking REST service based on spring-web-flux which is backed by Netty.

A collection of components built using reagent and beicon and bulma