All Projects → mechero → java-9-flow-reactive

mechero / java-9-flow-reactive

Licence: other
A sample application using Java 9's Flow API and SubmissionPublisher

Programming Languages

java
68154 projects - #9 most used programming language

Projects that are alternatives of or similar to java-9-flow-reactive

Scramjet
Simple yet powerful live data computation framework
Stars: ✭ 171 (+434.38%)
Mutual labels:  reactive-programming
Mpx
Mpx,一款具有优秀开发体验和深度性能优化的增强型跨端小程序框架
Stars: ✭ 2,913 (+9003.13%)
Mutual labels:  reactive-programming
RxjavaSamples
This repo is a container for some samples using RXJAVA2 samples
Stars: ✭ 12 (-62.5%)
Mutual labels:  reactive-programming
Frideos flutter
An all-in-one Fllutter package for state management, reactive objects, animations, effects, timed widgets etc.
Stars: ✭ 187 (+484.38%)
Mutual labels:  reactive-programming
React Easy State
Simple React state management. Made with ❤️ and ES6 Proxies.
Stars: ✭ 2,459 (+7584.38%)
Mutual labels:  reactive-programming
Xcell
Tiny library for building reactive, spreadsheet-like calculations in JavaScript
Stars: ✭ 253 (+690.63%)
Mutual labels:  reactive-programming
Fpgo
Monad, Functional Programming features for Golang
Stars: ✭ 165 (+415.63%)
Mutual labels:  reactive-programming
vuse-rx
Vue 3 + rxjs = ❤
Stars: ✭ 52 (+62.5%)
Mutual labels:  reactive-programming
Camelotia
Cross-platform .NET sample GUI app for cloud file management. Built with ReactiveUI, AvaloniaUI, Universal Windows Platform, Xamarin Forms, and WPF, runs on Windows, Linux, Mac and Android.
Stars: ✭ 221 (+590.63%)
Mutual labels:  reactive-programming
kendo-vue
Issue tracker - Kendo UI for Vue http://www.telerik.com/kendo-vue-ui/
Stars: ✭ 49 (+53.13%)
Mutual labels:  reactive-programming
Xstream
An extremely intuitive, small, and fast functional reactive stream library for JavaScript
Stars: ✭ 2,259 (+6959.38%)
Mutual labels:  reactive-programming
Slick
A Reactive MVP Framework which is Slick to use
Stars: ✭ 201 (+528.13%)
Mutual labels:  reactive-programming
flutter-form-with-validation-BLOC
This form and validation functions are created by using the BLOC pattern with RxDart instead of using StatefulWidget
Stars: ✭ 63 (+96.88%)
Mutual labels:  reactive-programming
Akavache
An asynchronous, persistent key-value store created for writing desktop and mobile applications, based on SQLite3. Akavache is great for both storing important data as well as cached local data that expires.
Stars: ✭ 2,185 (+6728.13%)
Mutual labels:  reactive-programming
IntroduceToEclicpseVert.x
This repository contains the code of Vert.x examples contained in my articles published on platforms such as kodcu.com, medium, dzone. How to run each example is described in its readme file.
Stars: ✭ 27 (-15.62%)
Mutual labels:  reactive-programming
Vertx Blueprint Todo Backend
Vert.x Blueprint Project - A reactive todo-backend implementation using Vert.x and various persistence
Stars: ✭ 169 (+428.13%)
Mutual labels:  reactive-programming
Reactivelists
React-like API for UITableView & UICollectionView
Stars: ✭ 250 (+681.25%)
Mutual labels:  reactive-programming
ddd-generic-java
Domain-Driven Design - Subdominio Generico en JAVA
Stars: ✭ 37 (+15.63%)
Mutual labels:  reactive-programming
hodux
🚀Simple reactive React Hooks state management.
Stars: ✭ 29 (-9.37%)
Mutual labels:  reactive-programming
proxybuilder
www.proxybuilder.org
Stars: ✭ 19 (-40.62%)
Mutual labels:  java9

Java 9 Flow Example - TPD.io

The Reactive Magazine Publisher

Description

This is a simple project that shows how to use Java 9's Flow API to create a Reactive Programming example. It's based on a story: a Magazine Publisher with two different Subscribers, one of them being too slow to pick items.

The guide Reactive Programming with Java 9 Flow explains this code and the fictional use case with detail.

Code Structure

  • ReactiveFlowApp creates a Publisher using Java 9's SubmissionPublisher. It implements backpressure and dropping of items by setting a timeout for subscribers.
  • MagazineSubscriber implements Flow.Subscriber and let you experiment what happens when subscribers are slow.
  • ColorConsoleAppender has nothing to do with Java 9 or reactive programming, is just a utility class to set colors to log messages so the result can be understood easier.

Feedback and Contribution

If you find something wrong, feel free to create an issue. Same if you have questions. If you want to help me creating more code examples you can buy me a coffee.

Note that the project description data, including the texts, logos, images, and/or trademarks, for each open source project belongs to its rightful owner. If you wish to add or remove any projects, please contact us at [email protected].