Topic

reactive-streams

Repositories (573)

r2
r2 rsocket-community Java

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

7
fast-reactive-fs2
fast-reactive-fs2 dokwork Scala

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

7
niagara
niagara prange Kotlin

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

7
reajames
reajames dobrynya Scala

JMS in the terms of Reactive Streams

7
webcrawler
webcrawler hafidsousa Java

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

7
reactive-spring-deepdive
reactive-spring-deepdive mkheck Java
7
stonks-platform-ng-kt
stonks-platform-ng-kt fynnfluegge TypeScript

Kotlin/Angular Realtime Stock Monitor

7
netifi-r2dbc-example
netifi-r2dbc-example gregwhitaker TSQL

Example of using R2DBC for Database Access with RSocket and Netifi

6
reacto
reacto soundvibe Java

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

6
azure-event-hubs-reactive
azure-event-hubs-reactive Azure Scala

Akka Reactive Streaming for Azure Event Hubs

6
springboot-rsocketsetup-example
springboot-rsocketsetup-example gregwhitaker Java

Example of sending RSocket Setup Payload with Spring Boot

6
toketi-iothub-to-cassandra
toketi-iothub-to-cassandra Azure Scala

Azure IoT connector to feed connected devices telemetry to Apache Cassandra

6
akka-zk
akka-zk radekg Scala

Reactive akka ZooKeeper client

6
reactive-integration-with-akka-streams-and-alpakka
reactive-integration-with-akka-streams-and-alpakka rucek Java

Example data processing pipeline with Akka Streams and Alpakka

6
RxSerialPort
RxSerialPort nilsauf C#

Extensions to make SerialPort reactive

6
learn-reactive
learn-reactive jsonberry JavaScript

A collection of learning resources for topics related to reactive programming

6
spring-boot-microservices-docker
spring-boot-microservices-docker rbarbioni Java

Spring-Boot Microservices Reactive Application with MongoDB and Docker container

6
squatch-android
squatch-android saasquatch Java

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

6
wms
wms silaev Java

Small WMS (warehouse management system)

6
RxKotlinDownloader
RxKotlinDownloader oussaki Kotlin

Reactive Downloader Library for Android ( Kotlin )

5
rsocket-reactive-chat
rsocket-reactive-chat mkrzywanski Java

Chat server built with RSocket and MongoDB change streams

5
pekko-connectors-samples
pekko-connectors-samples apache Java

Example projects building Reactive Integrations using Apache Pekko Connectors

5
the-observable-plugin-system
the-observable-plugin-system ReactiveHTML TypeScript

A stream-oriented messagebus for modular reactive applications

5
ng
ng bitfiber TypeScript

Reactive State and Async Workflow Management Library for Angular

5
Signal
Signal Fenrur Kotlin

⚡️ Reactive signals MultiPlatform for Kotlin

5
epcis-testdata-generator
epcis-testdata-generator openepcis Vue

EPCIS 2.0 Testdata Generator

5
openepcis-document-converter
openepcis-document-converter openepcis Java

Convert GS1 EPCIS events from JSON-LD to XML format and vice versa.

5
1e14
1e14 1e14 TypeScript

Tools for building function graphs

5
reactive-dev
reactive-dev armdev Java

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

5
segystream
segystream SereneAnt Scala

Reactively streaming SEG-Y parser

5
streamingpool-core
streamingpool-core streamingpool Java
5
netifi-requeststream-example
netifi-requeststream-example gregwhitaker Java

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

5
reactivity
reactivity reactivity-io

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

5
Concurrency-Utilities
Concurrency-Utilities hlovatt Swift

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

5
rx-scala-wrapper
rx-scala-wrapper exante Scala

Straightforward rxjava wrapper for scala

5
Laplace
Laplace Shirleh Kotlin

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

5
springboot-rsocketmetadatapush-example
springboot-rsocketmetadatapush-example gregwhitaker Java

Example of using RSocket Metadata Push in Spring Boot

5
webflux-rsocket-example
webflux-rsocket-example gregwhitaker Java

Example of using RSocket with Spring WebFlux

5
spring-reactive-cassandra-kotlin-example
spring-reactive-cassandra-kotlin-example avthart Kotlin

Spring Boot Reactive Cassandra Kotlin

5
gnip-consumer
gnip-consumer jeroenr Scala

Consuming Gnip streaming API using Akka HTTP / Streams 2.4.2

5
rx-oanda
rx-oanda MartinSeeler Scala

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

5
background_tts_stt
background_tts_stt umair13adil Java

A flutter project to run speech recognition service in background.

4
reactive-liferay
reactive-liferay cbianco Java
4
reactive-stream-java9
reactive-stream-java9 aboullaite Java

small demo of Java9 reactive stream

4
potok-rumu
potok-rumu pepe Clojure

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

4
reactor-core-scala
reactor-core-scala sinwe Scala

Scala wrapper for reactor-core

4
reactive_weather_app
reactive_weather_app utkarshdbodake Dart

Flutter weather app written using Reactive way.

4
xoom-symbio-jdbc
xoom-symbio-jdbc vlingo Java

The VLINGO XOOM SYMBIO implementation for JDBC for Reactive storage using Event-Sourcing, Key-Value, and Object storage.

4
reactor-rust
reactor-rust jjeffcaii Rust

A prototype of reactor in Rust.

4
chronicle-flux
chronicle-flux matgabriel Java

A reactive driver for chronicle-queue

4