Topic: "reactive-streams"
Azure/azure-event-hubs-reactive 📦
Akka Reactive Streaming for Azure Event Hubs
Language: Scala - Size: 1.36 MB - Last synced at: about 1 year ago - Pushed at: over 5 years ago - Stars: 6 - Forks: 5
soundvibe/reacto
Functional reactive microservices for the JVM. Uses Observables for composing event streams.
Language: Java - Size: 588 KB - Last synced at: 2 months ago - Pushed at: over 6 years ago - Stars: 6 - Forks: 3
rucek/reactive-integration-with-akka-streams-and-alpakka
Example data processing pipeline with Akka Streams and Alpakka
Language: Java - Size: 58.6 KB - Last synced at: over 2 years ago - Pushed at: over 6 years ago - Stars: 6 - Forks: 2
mkheck/reactive-spring-deepdive
Language: Java - Size: 59.6 KB - Last synced at: over 2 years ago - Pushed at: about 7 years ago - Stars: 6 - Forks: 5
avthart/spring-reactive-cassandra-kotlin-example
Spring Boot Reactive Cassandra Kotlin
Language: Kotlin - Size: 8.79 KB - Last synced at: almost 2 years ago - Pushed at: about 7 years ago - Stars: 6 - Forks: 0
dobrynya/reajames
JMS in the terms of Reactive Streams
Language: Scala - Size: 162 KB - Last synced at: about 2 years ago - Pushed at: over 7 years ago - Stars: 6 - Forks: 3
rbarbioni/spring-boot-microservices-docker
Spring-Boot Microservices Reactive Application with MongoDB and Docker container
Language: Java - Size: 20.5 KB - Last synced at: almost 2 years ago - Pushed at: over 7 years ago - Stars: 6 - Forks: 4
Azure/toketi-iothub-to-cassandra 📦
Azure IoT connector to feed connected devices telemetry to Apache Cassandra
Language: Scala - Size: 24.4 KB - Last synced at: 1 day ago - Pushed at: almost 8 years ago - Stars: 6 - Forks: 7
radekg/akka-zk 📦
Reactive akka ZooKeeper client
Language: Scala - Size: 57.6 KB - Last synced at: about 1 year ago - Pushed at: over 8 years ago - Stars: 6 - Forks: 0
saasquatch/squatch-android
Official Android SDK for SaaSquatch. REST API wrapper and widgets in Android WebViews
Language: Java - Size: 333 KB - Last synced at: 13 days ago - Pushed at: 13 days ago - Stars: 5 - Forks: 0
pjeby/uneventful
Declarative Event-Driven Programming: signals plus streams, minus the seams!
Language: TypeScript - Size: 514 KB - Last synced at: 13 days ago - Pushed at: 3 months ago - Stars: 5 - Forks: 0
nilsauf/RxSerialPort
Extensions to make SerialPort reactive
Language: C# - Size: 338 KB - Last synced at: about 1 month ago - Pushed at: 3 months ago - Stars: 5 - Forks: 1
apache/pekko-connectors-samples
Example projects building Reactive Integrations using Apache Pekko Connectors
Language: Java - Size: 446 KB - Last synced at: 2 days ago - Pushed at: 5 months ago - Stars: 5 - Forks: 3
bitfiber/ng
Reactive State and Async Workflow Management Library for Angular
Language: TypeScript - Size: 1.91 MB - Last synced at: 14 days ago - Pushed at: 6 months ago - Stars: 5 - Forks: 0
mkrzywanski/rsocket-reactive-chat
Chat server built with RSocket and MongoDB change streams
Language: Java - Size: 33.9 MB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 5 - Forks: 0
Blamer-io/hub
Blamer Core Engine
Language: Java - Size: 90.8 KB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 5 - Forks: 1
jsonberry/learn-reactive
A collection of learning resources for topics related to reactive programming
Language: JavaScript - Size: 160 KB - Last synced at: over 2 years ago - Pushed at: over 2 years ago - Stars: 5 - Forks: 2
exante/rx-scala-wrapper
Straightforward rxjava wrapper for scala
Language: Scala - Size: 135 KB - Last synced at: over 1 year ago - Pushed at: over 3 years ago - Stars: 5 - Forks: 2
streamingpool/streamingpool-core
Language: Java - Size: 728 KB - Last synced at: almost 2 years ago - Pushed at: about 4 years ago - Stars: 5 - Forks: 5
Shirleh/Laplace
Laplace is a Discord bot which collects statistics about a server and its users.
Language: Kotlin - Size: 267 KB - Last synced at: over 2 years ago - Pushed at: over 4 years ago - Stars: 5 - Forks: 0
gregwhitaker/springboot-rsocketmetadatapush-example
Example of using RSocket Metadata Push in Spring Boot
Language: Java - Size: 92.8 KB - Last synced at: about 2 months ago - Pushed at: over 4 years ago - Stars: 5 - Forks: 1
hlovatt/Concurrency-Utilities
NO LONGER MAINTAINED! Atomics, Futures, and Reactive-Streams for Swift
Language: Swift - Size: 139 KB - Last synced at: 5 months ago - Pushed at: almost 5 years ago - Stars: 5 - Forks: 0
gregwhitaker/netifi-requeststream-example
Example of using the request-stream interaction model with Netifi and RSocket
Language: Java - Size: 196 KB - Last synced at: about 2 months ago - Pushed at: over 5 years ago - Stars: 5 - Forks: 0
gregwhitaker/webflux-rsocket-example
Example of using RSocket with Spring WebFlux
Language: Java - Size: 85.9 KB - Last synced at: about 2 months ago - Pushed at: over 5 years ago - Stars: 5 - Forks: 3
1e14/1e14
Tools for building function graphs
Language: TypeScript - Size: 306 KB - Last synced at: 11 days ago - Pushed at: about 6 years ago - Stars: 5 - Forks: 0
reactivity-io/reactivity
Reactivity is an agile tool that allows you to manage the activity that matters in a free, 100% OSS and reactive web application.
Size: 414 KB - Last synced at: about 1 year ago - Pushed at: over 7 years ago - Stars: 5 - Forks: 1
oussaki/RxKotlinDownloader
Reactive Downloader Library for Android ( Kotlin )
Language: Kotlin - Size: 148 KB - Last synced at: over 2 years ago - Pushed at: over 7 years ago - Stars: 5 - Forks: 2
MartinSeeler/rx-oanda
Reactive Oanda API wrapper for Scala based on akka-streams and akka-http.
Language: Scala - Size: 646 KB - Last synced at: 2 days ago - Pushed at: almost 9 years ago - Stars: 5 - Forks: 2
jeroenr/gnip-consumer
Consuming Gnip streaming API using Akka HTTP / Streams 2.4.2
Language: Scala - Size: 1.01 MB - Last synced at: about 1 year ago - Pushed at: over 9 years ago - Stars: 5 - Forks: 1
vlingo/xoom-symbio-jdbc
The VLINGO XOOM SYMBIO implementation for JDBC for Reactive storage using Event-Sourcing, Key-Value, and Object storage.
Language: Java - Size: 1.33 MB - Last synced at: about 2 months ago - Pushed at: 5 months ago - Stars: 4 - Forks: 11
lhotari/reactive-iot-backend-ApacheCon2021
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
Language: Java - Size: 619 KB - Last synced at: 2 months ago - Pushed at: 7 months ago - Stars: 4 - Forks: 2
mtumilowicz/java12-introduction-to-reactive-programming-workshop
Java reactive streams workshop: basic implementations of Publisher, Subscriber, Subscription and Processor.
Language: Java - Size: 163 KB - Last synced at: 2 months ago - Pushed at: about 1 year ago - Stars: 4 - Forks: 1
DuartBreedt/Android-Concepts-Reference
A single repository to learn the basics of Android in Java without all the fluff.
Language: Java - Size: 160 KB - Last synced at: over 2 years ago - Pushed at: over 2 years ago - Stars: 4 - Forks: 0
lifeart/ember-cerebraljs
Ember Cerebral
Language: JavaScript - Size: 65.4 KB - Last synced at: about 21 hours ago - Pushed at: about 4 years ago - Stars: 4 - Forks: 0
gregwhitaker/netifi-springboot-example-screencast
Example Code for Netifi Spring Boot Screencast
Language: Java - Size: 98.6 KB - Last synced at: 4 months ago - Pushed at: over 5 years ago - Stars: 4 - Forks: 0
jjeffcaii/reactor-rust
A prototype of reactor in Rust.
Language: Rust - Size: 61.5 KB - Last synced at: 23 days ago - Pushed at: over 5 years ago - Stars: 4 - Forks: 2
cbianco/reactive-liferay
Language: Java - Size: 91.8 KB - Last synced at: over 1 year ago - Pushed at: over 5 years ago - Stars: 4 - Forks: 1
SereneAnt/segystream
Reactively streaming SEG-Y parser
Language: Scala - Size: 30.3 KB - Last synced at: over 2 years ago - Pushed at: over 6 years ago - Stars: 4 - Forks: 0
janstenpickle/otters
Streaming cats
Language: Scala - Size: 161 KB - Last synced at: 3 months ago - Pushed at: over 6 years ago - Stars: 4 - Forks: 1
matgabriel/chronicle-flux
A reactive driver for chronicle-queue
Language: Java - Size: 146 KB - Last synced at: over 1 year ago - Pushed at: almost 7 years ago - Stars: 4 - Forks: 2
reactive-systems-hamburg/docs
Shared documents for Reactive Systems Hamburg
Size: 14.6 KB - Last synced at: over 1 year ago - Pushed at: about 7 years ago - Stars: 4 - Forks: 2
aboullaite/reactive-stream-java9
small demo of Java9 reactive stream
Language: Java - Size: 3.03 MB - Last synced at: 3 months ago - Pushed at: over 7 years ago - Stars: 4 - Forks: 5
gdrouet/nightclazz-spring5
Spring 5 exercices
Language: Java - Size: 69.3 KB - Last synced at: 2 months ago - Pushed at: almost 8 years ago - Stars: 4 - Forks: 4
sinwe/reactor-core-scala 📦
Scala wrapper for reactor-core
Language: Scala - Size: 553 KB - Last synced at: over 1 year ago - Pushed at: about 8 years ago - Stars: 4 - Forks: 1
pepe/potok-rumu
Experiments with funcool/potok and tonsky/rum. Reactive streams FTW!
Language: Clojure - Size: 16.6 KB - Last synced at: 6 days ago - Pushed at: about 8 years ago - Stars: 4 - Forks: 2
melgenek/mysql-reactive
Mysql X DevApi wrapped with Spring Reactor
Language: Kotlin - Size: 52.7 KB - Last synced at: about 1 year ago - Pushed at: over 8 years ago - Stars: 4 - Forks: 1
a-ignatov-parc/rx-telegram-bot
Telegram bot built with reactive streams
Language: JavaScript - Size: 18.6 KB - Last synced at: 3 months ago - Pushed at: over 8 years ago - Stars: 4 - Forks: 0
openepcis/openepcis-document-converter
Convert GS1 EPCIS events from JSON-LD to XML format and vice versa.
Language: Java - Size: 543 KB - Last synced at: 19 days ago - Pushed at: 19 days ago - Stars: 3 - Forks: 1
openepcis/epcis-testdata-generator
EPCIS 2.0 Testdata Generator
Language: Vue - Size: 3.86 MB - Last synced at: 28 days ago - Pushed at: 28 days ago - Stars: 3 - Forks: 2
bitfiber/rx
Reactive State and Async Workflow Management Library based on RxJS
Language: TypeScript - Size: 1.74 MB - Last synced at: 19 days ago - Pushed at: 6 months ago - Stars: 3 - Forks: 0
romalev/reactive-spring-web-flux-service
Simple POC of nonblocking REST service based on spring-web-flux which is backed by Netty.
Language: Java - Size: 86.9 KB - Last synced at: about 2 months ago - Pushed at: over 1 year ago - Stars: 3 - Forks: 3
alexanderlinne/kled
Reactive Extensions for async Rust
Language: Rust - Size: 431 KB - Last synced at: 7 days ago - Pushed at: about 2 years ago - Stars: 3 - Forks: 0
alexandria-oss/streams
:envelope: Streams is a stream-based communication toolkit made for data-in-motion platforms
Language: Go - Size: 178 KB - Last synced at: about 1 year ago - Pushed at: about 2 years ago - Stars: 3 - Forks: 0
timberbacklabs/reactiveProgramming
Getting you started with Reactive Programming in Java.
Language: Java - Size: 285 KB - Last synced at: over 2 years ago - Pushed at: almost 4 years ago - Stars: 3 - Forks: 0
gregwhitaker/sqs-priority-client
Reactive wrapper around the Amazon SQS client that allows reading from multiple queues with weighted priority.
Language: Java - Size: 594 KB - Last synced at: 4 months ago - Pushed at: about 4 years ago - Stars: 3 - Forks: 1
pawelkaczor/telemetry-reports
Sample app combining zio-streams, akka-streams, zio-prelude (Associative, Identity type classes)
Language: Scala - Size: 54.7 KB - Last synced at: over 2 years ago - Pushed at: over 4 years ago - Stars: 3 - Forks: 1
norbertoritzmann/stock-tickers-spring-reactive
Stock market ticker Spring Boot reactive example
Language: Java - Size: 17.6 KB - Last synced at: over 2 years ago - Pushed at: over 4 years ago - Stars: 3 - Forks: 1
gregwhitaker/rsocket-channel-example
Example of using the channel interaction model with RSocket
Language: Java - Size: 77.1 KB - Last synced at: 17 days ago - Pushed at: over 4 years ago - Stars: 3 - Forks: 0
gregwhitaker/rsocket-backpressure-example
Example of using Backpressure with RSocket
Language: Java - Size: 68.4 KB - Last synced at: 3 months ago - Pushed at: over 4 years ago - Stars: 3 - Forks: 1
phantasmicmeans/reactive-streams-spring-boot
reactive programming
Language: Java - Size: 126 KB - Last synced at: over 2 years ago - Pushed at: over 4 years ago - Stars: 3 - Forks: 2
umair13adil/background_tts_stt
A flutter project to run speech recognition service in background.
Language: Java - Size: 79.1 KB - Last synced at: over 2 years ago - Pushed at: about 5 years ago - Stars: 3 - Forks: 0
akarnokd/loom-interop-experiments
Code to experiment with Project Loom continuation/fiber API.
Language: Java - Size: 66.4 KB - Last synced at: 3 months ago - Pushed at: over 5 years ago - Stars: 3 - Forks: 1
gregwhitaker/netifi-acmeshoes
E-Commerce Example of Composing Microservices with Netifi, RSocket, and Spring Boot
Language: CSS - Size: 490 KB - Last synced at: about 2 months ago - Pushed at: over 5 years ago - Stars: 3 - Forks: 3
pbaun/rere
Reactive RethinkDB driver for Scala
Language: Scala - Size: 438 KB - Last synced at: almost 2 years ago - Pushed at: over 6 years ago - Stars: 3 - Forks: 0
enpassant/rapids
Reducing Microservice Complexity with Kafka and Reactive Streams
Language: Scala - Size: 1.3 MB - Last synced at: 3 months ago - Pushed at: over 6 years ago - Stars: 3 - Forks: 0
slicebox/dcm4che-streams
Akka-streams integration with dcm4che for streaming DICOM IO in Scala.
Language: Scala - Size: 717 KB - Last synced at: almost 2 years ago - Pushed at: almost 7 years ago - Stars: 3 - Forks: 0
longevityframework/stream-adapter
Conversions between various Scala streaming libraries
Language: Scala - Size: 75.2 KB - Last synced at: 3 months ago - Pushed at: about 7 years ago - Stars: 3 - Forks: 0
aalobaidi/AerospikeReactor
Non-Blocking Reactive Driver for Aerospike with Reactor
Language: Java - Size: 61.5 KB - Last synced at: almost 2 years ago - Pushed at: about 7 years ago - Stars: 3 - Forks: 0
Thearith/GitHub-Search
Android application for searching for GitHub repositories
Language: Kotlin - Size: 11 MB - Last synced at: over 2 years ago - Pushed at: over 7 years ago - Stars: 3 - Forks: 0
noxecane/irinse
A collection of components built using reagent and beicon and bulma
Language: Clojure - Size: 57.6 KB - Last synced at: 5 days ago - Pushed at: about 8 years ago - Stars: 3 - Forks: 0
jesperancinha/sea-shell-archiver
This is web application made specifically to study a reactive archiitectur.
Language: Kotlin - Size: 3.88 MB - Last synced at: 3 days ago - Pushed at: 3 days ago - Stars: 2 - Forks: 3
v0id-user/Postgres-Reactive-SSE-Example
Experimental real-time newsletter application demonstrating PostgreSQL's NOTIFY/LISTEN with Server-Sent Events (SSE) for reactive updates. Built with FastAPI and modern async Python.
Language: Python - Size: 1.54 MB - Last synced at: 5 months ago - Pushed at: 5 months ago - Stars: 2 - Forks: 1
ical4j/ical4j-integration
iCalendar support for Enterprise Integration Patterns (EIP)
Language: Java - Size: 496 KB - Last synced at: 6 months ago - Pushed at: 6 months ago - Stars: 2 - Forks: 0
saasquatch/saasquatch-java-sdk
SaaSquatch SDK for Java
Language: Java - Size: 587 KB - Last synced at: 2 months ago - Pushed at: 7 months ago - Stars: 2 - Forks: 0
QinArmy/jdbd
reactive java database driver SPI
Language: Java - Size: 3.86 MB - Last synced at: 12 months ago - Pushed at: 12 months ago - Stars: 2 - Forks: 1
Artemas-Muzanenhamo/gov-poc
POC demo of Microservices Architecture with Spring Boot & Spring Cloud
Language: Java - Size: 897 KB - Last synced at: about 1 year ago - Pushed at: about 1 year ago - Stars: 2 - Forks: 0
b-palaniappan/reactive-app
Springboot Webflux reactive app with Mongo Reactive
Language: Groovy - Size: 113 KB - Last synced at: about 1 month ago - Pushed at: almost 2 years ago - Stars: 2 - Forks: 0
j3t/mvnio
Repository for Maven artifacts which uses S3 buckets as storage provider.
Language: Java - Size: 343 KB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 2 - Forks: 1
ICubeSystems/nceph-network
Reactive non-blocking event broker to facilitate inter service (microservices) communication using an event driven architecture.
Language: Java - Size: 593 KB - Last synced at: about 2 years ago - Pushed at: about 2 years ago - Stars: 2 - Forks: 2
YasTechOrg/weeki
Weeki is an online crm for Germany and European Union
Language: Vue - Size: 2.21 MB - Last synced at: over 1 year ago - Pushed at: over 2 years ago - Stars: 2 - Forks: 0
oracle-japan/ochacafe-reactive
挑戦! JavaでReactiveプログラミング - Oracle Cloud Hangout Cafe - Season 3 #4
Language: Java - Size: 117 KB - Last synced at: 3 months ago - Pushed at: over 2 years ago - Stars: 2 - Forks: 1
adityagarde/java-reactive-programming
Reactive Programming in Java with Project Reactor.
Language: Java - Size: 173 KB - Last synced at: over 2 years ago - Pushed at: about 3 years ago - Stars: 2 - Forks: 0
doorgan/untitled
A simple custom elements helper based on uhtml and the meiosis pattern ideas.
Language: TypeScript - Size: 1.02 MB - Last synced at: 13 days ago - Pushed at: over 3 years ago - Stars: 2 - Forks: 0
oktadev/okta-reactive-service-example Fork of indiepopart/reactive-service
Example code for the tutorial "How to Prevent Reactive Java Applications from Stalling"
Language: Java - Size: 58.6 KB - Last synced at: about 1 year ago - Pushed at: almost 4 years ago - Stars: 2 - Forks: 3
sleipnir/rsocketx
RSocket Protocol for Elixir
Language: Elixir - Size: 8.79 KB - Last synced at: 3 months ago - Pushed at: almost 4 years ago - Stars: 2 - Forks: 0
loreanvictor/rx-q
Queued Observables
Language: TypeScript - Size: 59.6 KB - Last synced at: 8 days ago - Pushed at: about 4 years ago - Stars: 2 - Forks: 1
spapageo/reactor-guava-eventbus
Expose the events propagated through the guava event-bus as a reactor Flux
Language: Java - Size: 16.6 KB - Last synced at: about 1 year ago - Pushed at: over 4 years ago - Stars: 2 - Forks: 0
enryold/quasar-flow
Handle data flows using quasar fibers and reactive-streams.
Language: Java - Size: 1.52 MB - Last synced at: over 2 years ago - Pushed at: almost 5 years ago - Stars: 2 - Forks: 2
Discord4J-Addons/D4J-Rx 📦
A set of reactive extensions for Discord4J
Language: Java - Size: 69.3 KB - Last synced at: almost 2 years ago - Pushed at: about 5 years ago - Stars: 2 - Forks: 0
frideosapps/childpugh
An example of the Child-Pugh clinical score calculor built with Flutter and the BLoC pattern
Language: Dart - Size: 82 KB - Last synced at: 4 months ago - Pushed at: over 5 years ago - Stars: 2 - Forks: 0
netifi-proteus/proteus-httpgateway 📦
Gateway that allows bridging HTTP and Netifi Proteus
Language: Java - Size: 923 KB - Last synced at: almost 2 years ago - Pushed at: about 6 years ago - Stars: 2 - Forks: 3
daggerok/reactive-es-cqrs-jms-app
in progress: Reactive WebFlux EventSourced CQRS spring-integration-jms app
Language: Kotlin - Size: 79.1 KB - Last synced at: 4 months ago - Pushed at: over 6 years ago - Stars: 2 - Forks: 0
calvinlfer/reactive-s3-sqs-extended-library
The S3 SQS extended library built on Alpakka with configurable delivery semantics
Language: Scala - Size: 4.88 KB - Last synced at: 2 days ago - Pushed at: over 6 years ago - Stars: 2 - Forks: 1
rhokstar/dart_flutter_login_bloc
Form state, form validation, BLoC, Providers, RxDart, Reactive Programming, and more!
Language: Dart - Size: 51.8 KB - Last synced at: over 1 year ago - Pushed at: over 6 years ago - Stars: 2 - Forks: 0
odrianoaliveira/spring-stream-reactive-blocking_vs_nonblocking
learning reactive stream and comparing the behavior between a blocking call not wrapped with Mono.fromCallable vs wrapped.
Language: Java - Size: 45.9 KB - Last synced at: over 1 year ago - Pushed at: almost 7 years ago - Stars: 2 - Forks: 0
jzallas/RxDisposal
A convenient 'garbage disposal' that can hook into an rx stream.
Language: Java - Size: 244 KB - Last synced at: about 1 year ago - Pushed at: about 7 years ago - Stars: 2 - Forks: 1
lostintime/node-rx-stream
Reactive Streams implementation with TypeScript
Language: TypeScript - Size: 141 KB - Last synced at: 23 days ago - Pushed at: over 7 years ago - Stars: 2 - Forks: 0
pwittchen/java-flow-experiments
Experimenting with Reactive Streams in Java 8 and Java 9. This repository is prepared for my talk "Get ready for java.util.concurrent.Flow!" at JDD 2017 Conference in Kraków, Poland
Language: Java - Size: 224 KB - Last synced at: about 1 month ago - Pushed at: over 7 years ago - Stars: 2 - Forks: 2
tuleism/typeracer
a clone of the popular typing game
Language: Scala - Size: 61.5 KB - Last synced at: over 1 year ago - Pushed at: over 8 years ago - Stars: 2 - Forks: 1
archit47/Akka-Streams-Examples
Akka Streams Explored: this repository consists of examples on Akka Streams.
Language: Scala - Size: 28.3 KB - Last synced at: over 2 years ago - Pushed at: over 8 years ago - Stars: 2 - Forks: 0
