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

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

shiang/flutter-form-with-validation-BLOC

This form and validation functions are created by using the BLOC pattern with RxDart instead of using StatefulWidget

Language: Dart - Size: 104 KB - Last synced at: over 1 year ago - Pushed at: almost 7 years ago - Stars: 63 - Forks: 16

vapor-community/async

⏱ Promises and reactive-streams in Swift built for high-performance and scalability.

Language: Swift - Size: 352 KB - Last synced at: about 21 hours ago - Pushed at: over 6 years ago - Stars: 35 - Forks: 7

muoncore/photon

Photon is an event store with cold+hot event streaming

Language: Clojure - Size: 8.55 MB - Last synced at: about 2 months ago - Pushed at: almost 8 years ago - Stars: 23 - Forks: 3

Azure/toketi-iothubreact 📦

Akka Stream library for Azure IoT Hub

Language: Scala - Size: 1.55 MB - Last synced at: 4 months ago - Pushed at: about 5 years ago - Stars: 39 - Forks: 21

tawfik-s/reactive-java-workshop Fork of koushikkothagal/reactive-java-workshop

my solutions for reactive workshop exercises

Language: Java - Size: 12.7 KB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 1 - Forks: 0

michalzeman/reactor-ddd

Reactive implementation of bank account example using spring reactor and DDD

Language: Java - Size: 240 KB - Last synced at: about 1 year ago - Pushed at: over 1 year ago - Stars: 12 - Forks: 6

fineconstant/spring-boot-2-reactive 📦

Demo project for Spring 5 and Reactor with Angular and RxJs

Language: JavaScript - Size: 105 KB - Last synced at: over 1 year ago - Pushed at: over 6 years ago - Stars: 11 - Forks: 9

Superdev0103/react-spring-project

Spring 5 Reactive playground

Language: Java - Size: 2.42 MB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 12 - Forks: 0

bszwej/mongodb-s3-stream-example

MongoDB collection backup and restore to/from Amazon S3 using Akka Streams and Alpakka.

Language: Scala - Size: 14.6 KB - Last synced at: over 1 year ago - Pushed at: over 6 years ago - Stars: 10 - Forks: 4

nmarasoiu/chessCombinations

Given any number of chess pieces of same color Map[Piece, Int], print their arrangements that do not attack one another, if any

Language: Scala - Size: 310 KB - Last synced at: over 1 year ago - Pushed at: over 6 years ago - Stars: 1 - Forks: 0

AikoN76/reactive-example

Reactive Example from Srping Framework 5: Beginner to Guru

Language: Batchfile - Size: 45.9 KB - Last synced at: over 1 year ago - Pushed at: over 5 years ago - Stars: 0 - Forks: 0

1e14/1e14

Tools for building function graphs

Language: TypeScript - Size: 306 KB - Last synced at: about 22 hours ago - Pushed at: about 6 years ago - Stars: 5 - Forks: 0

pzmi/atm-simulator

PoC of simulation of withdrawals from a network of ATMs using the actor model. Part of my master thesis.

Language: JavaScript - Size: 960 KB - Last synced at: over 1 year ago - Pushed at: almost 6 years ago - Stars: 0 - Forks: 0

pzmi/excercise-reactive-pubilsher

Implementing a reactive streams publisher as an exercise

Language: Java - Size: 64.5 KB - Last synced at: over 1 year ago - Pushed at: about 3 years ago - Stars: 0 - Forks: 0

AndreasChristianson/gopher-pipes

Language: Go - Size: 106 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0

aleh-zhloba/postgresql-messaging

Cheap pub/sub for PostgreSQL-backed JVM applications

Language: Kotlin - Size: 145 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 0 - Forks: 0

hermannhueck/reactive-mongo-access

Reactive Access to MongoDB in Scala and Java

Language: Scala - Size: 23.1 MB - Last synced at: over 1 year ago - Pushed at: almost 6 years ago - Stars: 7 - Forks: 2

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

gilpark/RxStateMachine

Reacitve StateMachine for Unity 3D

Language: C# - Size: 3.65 MB - Last synced at: 2 months ago - Pushed at: over 6 years ago - Stars: 25 - Forks: 4

reacted-io/reacted

Actor based reactive java framework for microservices in local and distributed environment

Language: Java - Size: 2.34 MB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 30 - Forks: 4

LoopPerfect/rxterm

Functional reactive terminals in C++ ⚡⌨️

Language: C++ - Size: 58.6 KB - Last synced at: over 1 year ago - Pushed at: about 4 years ago - Stars: 262 - Forks: 28

trishagee/jb-stock-client

This is a Spring Boot and JavaFX Application that uses REST or RSocket to connect to a streaming prices service and display the prices on a line chart

Language: Java - Size: 85.9 KB - Last synced at: over 1 year ago - Pushed at: over 2 years ago - Stars: 63 - Forks: 33

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: 3 days ago - Pushed at: almost 8 years ago - Stars: 6 - Forks: 7

eduardomallmann/reactive-microservices

Reactive Microservices with Spring Reactive

Language: Java - Size: 68.4 KB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 0 - Forks: 0

matsluni/aws-spi-akka-http

This is an alternative implementation of the new aws java sdk v2 non-blocking async SPI. It provides an alternative to the built-in Netty implementation based on akka-http.

Language: Scala - Size: 193 KB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 33 - Forks: 16

Digitanalogik/spring-6-reactive-mongo

Reactive MongoDB with Spring Framework 6, Spring Boot 3 and Java 17

Language: Java - Size: 135 KB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 0 - Forks: 0

may-andro/Flutter-Github-Issues

A sample project with flutter clean arch.

Language: Dart - Size: 106 KB - Last synced at: almost 2 years ago - Pushed at: over 3 years ago - Stars: 1 - Forks: 0

Digitanalogik/spring-6-webclient

WebFlux WebClient: Streaming, non-blocking reactive API client with Spring Framework 6, Spring Boot 3 and Java 17

Language: Java - Size: 84 KB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 0 - 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

alexanderlinne/kled

Reactive Extensions for async Rust

Language: Rust - Size: 431 KB - Last synced at: 15 days ago - Pushed at: about 2 years ago - Stars: 3 - Forks: 0

gregwhitaker/gopher

A self-hosted Google "go" short-links system

Language: Java - Size: 180 KB - Last synced at: 4 months ago - Pushed at: about 5 years ago - Stars: 0 - Forks: 0

fr33m0nk/clj-alpakka-kafka

Clojure wrapper over Alpakka Kafka

Language: Clojure - Size: 93.8 KB - Last synced at: 2 days ago - Pushed at: over 1 year ago - Stars: 1 - Forks: 0

basoy/websiteMonitoringTool

Website Monitoring Tool: Spring Boot 5(react, webflux). Thymeleaf. Multi-module project. Ractive mongoDb. Lombok. Proxy. Multi-thread.

Language: Java - Size: 108 KB - Last synced at: almost 2 years ago - Pushed at: over 6 years ago - Stars: 1 - Forks: 0

nooose/reactive-streams

내가 보려고 만든 Reactive Streams 정리 저장소

Language: Java - Size: 184 KB - Last synced at: over 1 year ago - Pushed at: almost 2 years ago - Stars: 0 - Forks: 0

lebronjamesuit/social-media-angular14

Build a website to post confession online

Language: TypeScript - Size: 1.23 MB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 1 - Forks: 0

ssamparn/spring-cloud-event-streaming

Learning to build event-driven spring boot microservices for real-time stream processing with Spring Cloud Kafka Event Streaming

Language: Java - Size: 88.9 KB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 0 - 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

holkiew/yomenik

Webflux Cloud based battle simulator

Language: Java - Size: 86.2 MB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 0 - Forks: 0

Fbada006/Cook-Central

My capstone project in the Udacity Android Deveoper Nanodegree

Language: Kotlin - Size: 662 KB - Last synced at: almost 2 years ago - Pushed at: about 5 years ago - Stars: 0 - Forks: 0

untaljohanperez/scala-playground

Scala learning exercises from zero to hero

Language: Scala - Size: 1.03 MB - Last synced at: almost 2 years ago - Pushed at: about 5 years ago - Stars: 0 - Forks: 0

ruippeixotog/akka-stream-mon

Throughput and latency monitoring for Akka Streams

Language: Scala - Size: 28.3 KB - Last synced at: 3 months ago - Pushed at: over 7 years ago - Stars: 25 - 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

MikiLoz92/PacketX

ReactiveX extensions for dealing with packet-based communication systems.

Language: Kotlin - Size: 65.4 KB - Last synced at: almost 2 years ago - Pushed at: about 7 years ago - Stars: 1 - Forks: 1

hafidsousa/webcrawler

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

Language: Java - Size: 542 KB - Last synced at: 7 months ago - Pushed at: almost 8 years ago - Stars: 7 - Forks: 4

pwittchen/yaas-java-sdk 📦

YaaS (Hybris as a Service) Java SDK

Language: Java - Size: 146 KB - Last synced at: almost 2 years ago - Pushed at: over 6 years ago - Stars: 1 - Forks: 0

DuartBreedt/Android-Concepts-Reference-Kotlin

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

Language: Kotlin - Size: 229 KB - Last synced at: over 1 year ago - Pushed at: over 1 year ago - Stars: 13 - Forks: 0

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

PS00161093/spring-boot-reactive-webflux

Java Microservices using Spring boot, Spring Flux & Project reactor. Total 3 Microservices interacting with each other in non blocking fashion

Language: Java - Size: 221 KB - Last synced at: almost 2 years ago - Pushed at: almost 3 years ago - Stars: 0 - Forks: 0

l0s/reactive-comparison

Compares the ergonomics and performance of reactive and blocking API implementations

Language: Java - Size: 187 KB - Last synced at: almost 2 years ago - Pushed at: over 4 years ago - Stars: 0 - Forks: 0

adikm/reactive-kotlin-spring-boot

A showcase project using Spring WebFlux and Kotlin

Language: Kotlin - Size: 7.81 KB - Last synced at: almost 2 years ago - Pushed at: about 7 years ago - Stars: 10 - Forks: 0

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

a-poliakov/CloudFoundryDeployApp

App for deploy apps to Cloud Foundry (IBM or Pivotal)

Language: Java - Size: 9.77 KB - Last synced at: almost 2 years ago - Pushed at: almost 6 years ago - Stars: 0 - 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

kamesh-a/RxJs-code-snippets

RxJs Learning

Language: JavaScript - Size: 24.4 KB - Last synced at: almost 2 years ago - Pushed at: about 8 years ago - Stars: 1 - Forks: 1

tercanfurkan/openhours

Spring Reactive API with a functional endpoint responding with formatted store opening hours based on JSON requests

Language: Kotlin - Size: 76.2 KB - Last synced at: almost 2 years ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0

ssamparn/spring-microservices-assorted

The purpose of this project is to learn, develop and explore microservices using spring boot, spring cloud, event streaming

Language: Java - Size: 71.3 KB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 0 - Forks: 0

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

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

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

slicebox/dicom-streams

A streaming and non-blocking API for reading and processing DICOM data

Language: Scala - Size: 1.74 MB - Last synced at: almost 2 years ago - Pushed at: about 6 years ago - Stars: 1 - Forks: 6

ReactiveCouchbase/reactivecouchbase-rs-core

New ReactiveCouchbase driver using reactive-streams

Language: Scala - Size: 7.27 MB - Last synced at: about 2 months ago - Pushed at: about 7 years ago - Stars: 26 - Forks: 10

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

inexorgame-obsolete/inexor-rgf-core-frp 📦

Inexor - Reactive Graph Flow - Core - FRP

Language: Rust - Size: 87.9 KB - Last synced at: 7 days ago - Pushed at: over 2 years ago - Stars: 0 - 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: about 2 years ago - Stars: 2 - Forks: 0

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

memoria-io/archived-reactive 📦

Reactive Java Utilities (Project Reactor, Netty, Vavr)

Language: Java - Size: 1.78 MB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 1

jntakpe/mongo-reactor-adapter

MongoDB's Reactor adapter for ReactiveStreams driver

Language: Kotlin - Size: 275 KB - Last synced at: 2 months ago - Pushed at: over 2 years ago - Stars: 9 - Forks: 0

joesan/plant-simulator

Power Plant simulator service that can ramp up and down power producing units

Language: Scala - Size: 11.6 MB - Last synced at: almost 2 years ago - Pushed at: over 2 years ago - Stars: 26 - Forks: 7

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

angularconsulting/rx-service

Enhance your application services with Rx Service. This is simple and powerful library adds reactivity and consistency to your services while streamlining component communication. Based on the reliable RxJS BehaviorSubject, it's the perfect solution for powering up your application 🐱🦸‍♂️

Language: TypeScript - Size: 690 KB - Last synced at: 5 days ago - Pushed at: over 2 years ago - Stars: 12 - Forks: 0

yangbajing/akka-cookbook

提供清晰、实用的Akka应用指导

Language: Scala - Size: 2.57 MB - Last synced at: about 1 year ago - Pushed at: over 3 years ago - Stars: 31 - Forks: 1

zypherscript/spring-boot-reactive-playground

Getting Started With Spring Reactive :: Reactive, RouterFunction, RSocket (TODO: more functionality with testing)

Language: Java - Size: 136 KB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 0 - Forks: 0

j3t/mvnio

Repository for Maven artifacts which uses S3 buckets as storage provider.

Language: Java - Size: 343 KB - Last synced at: about 2 years ago - Pushed at: about 2 years ago - Stars: 2 - Forks: 1

mirego/trikot.streams 📦

Reactive Streams for Kotlin Multiplatform with mutability checks

Language: Kotlin - Size: 513 KB - Last synced at: 3 months ago - Pushed at: over 3 years ago - Stars: 33 - Forks: 1

softwaremill/reactive-streams-for-java-developers 📦

Language: Java - Size: 2.28 MB - Last synced at: about 1 year ago - Pushed at: almost 8 years ago - Stars: 17 - Forks: 10

EasyKotlin/kotlin-with-webflux

Kotlin 使用 Spring WebFlux 实现响应式编程

Language: Kotlin - Size: 76.2 KB - Last synced at: almost 2 years ago - Pushed at: over 7 years ago - Stars: 41 - Forks: 10

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

cqfn/rio 📦

Reactive Input Output objects for Java

Language: Java - Size: 220 KB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 24 - Forks: 3

mahmedMostafa/Popcorn-Dagger2-Retrofit2-Room-Mvvm-clean-Architecture-

A Movie app that heavily depends on dagger2 & clean architecture

Language: Java - Size: 393 KB - Last synced at: over 2 years ago - Pushed at: over 5 years ago - Stars: 19 - Forks: 3

zkoss-demo/rxzk

A ZK addon to provide event streams for RxJava.

Language: Java - Size: 32.2 KB - Last synced at: over 2 years ago - Pushed at: almost 3 years ago - Stars: 1 - Forks: 1

jeroenr/tepkin Fork of fehmicansaglam/tepkin

Reactive MongoDB Driver for Scala

Language: Scala - Size: 1.31 MB - Last synced at: 6 months ago - Pushed at: over 2 years ago - Stars: 17 - Forks: 5

danielcaldas/take-the-cat-to-the-party

Learn reactive programming with RxJS the fun way

Language: HTML - Size: 2.97 MB - Last synced at: 4 months ago - Pushed at: almost 5 years ago - Stars: 1 - Forks: 0

robsonkades/reactive-programming

Learning reactive programming with project-reactor

Language: Java - Size: 21.5 KB - Last synced at: 28 days ago - Pushed at: about 3 years ago - Stars: 1 - Forks: 0

noxecane/irinse

A collection of components built using reagent and beicon and bulma

Language: Clojure - Size: 57.6 KB - Last synced at: 3 days ago - Pushed at: about 8 years ago - Stars: 3 - Forks: 0

jjeffcaii/reactor-rust

A prototype of reactor in Rust.

Language: Rust - Size: 61.5 KB - Last synced at: about 1 month ago - Pushed at: over 5 years ago - Stars: 4 - Forks: 2

Unthrottled/mongo-images 📦

Ever wonder how you can create a full stack reactive application that also saves images? Well look no further! We've got Spring Webflux, Reactive Mongo Streams with GridFS, and Angular5!

Language: TypeScript - Size: 1.38 MB - Last synced at: over 2 years ago - Pushed at: over 6 years ago - Stars: 11 - Forks: 0

vic/pond

State aware Elixir functions without spawning processes

Language: Elixir - Size: 112 KB - Last synced at: 29 days ago - Pushed at: over 7 years ago - Stars: 27 - 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

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

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

adamldavis/reactive-streams-in-java

Code for "Reactive Streams in Java" book

Language: Java - Size: 37.1 KB - Last synced at: over 2 years ago - Pushed at: almost 7 years ago - Stars: 19 - Forks: 23

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

ronenhamias/scalecube-services 📦

v2.0 - ScaleCube Services provides a low latency Reactive Microservices library for serverless service registry and discovery based on gossip protocol and without single point-of-failure or bottlenecks.

Language: Java - Size: 3.06 MB - Last synced at: over 2 years ago - Pushed at: almost 7 years ago - Stars: 26 - Forks: 7

cjhowe-us/reactive-http-server 📦

Reactive Streams HTTP server

Language: Java - Size: 81.1 KB - Last synced at: 27 days ago - Pushed at: almost 6 years ago - Stars: 0 - Forks: 0

lxsmnsyc/reactive-extensions 📦

Reactive Extensions for JS

Language: JavaScript - Size: 240 KB - Last synced at: about 1 year ago - Pushed at: almost 5 years ago - Stars: 1 - Forks: 0

lxsmnsyc/is-reactive-streams 📦

Test whether an object is a Reactive Streams component

Language: JavaScript - Size: 196 KB - Last synced at: 18 days ago - Pushed at: over 4 years ago - Stars: 0 - Forks: 0

garethahealy/vertx-playground 📦

[Archived] Vert.x 3 homework playground

Language: Java - Size: 2.2 MB - Last synced at: 7 months ago - Pushed at: almost 7 years ago - Stars: 0 - Forks: 0

jvz/reactive-streams-examples 📦

Example implementations of Java reactive stream classes

Language: Java - Size: 12.7 KB - Last synced at: 9 months ago - Pushed at: over 8 years ago - Stars: 0 - Forks: 0