politrons/reactive

Author Pablo Picouto Garcia

Is this repo useful? Please ⭑Star this repository and share the love.

Here we cover with examples the most famous reactive libraries that you can find in the market.

ReactiveX

Marble diagrams are not clear enough?.

Here we cover with some practical examples, the most common use of the ReactiveX platform for Java.

RxScala examples here

• Contactable

  

  • HotObservable

• Combining

  

  • Chain
  • Concat
  • Merge
  • Zip
  • Switch

• Creating

  

  • Create
  • Defer
  • Interval
  • Subscription

• Filtering

  

  • Debounce
  • Distinct
  • Skip
  • Take
  • First *Run java classes

• Transforming

  

  • Map
  • FlatMap
  • GroupBy
  • Scan
  • Collect
  • Buffer
  • Window
  • Compose

• Scheduler

  

  • Asynchronous

• Errors

  

  • Exceptions

• Utils

  • Delay
  • AmbConditional
  • Cache
  • ToBlocking

• Single An Observable that just emit 1 item through the pipeline.

  • SingleFeatures

• Relay A subject which subscribe observers and keep the pipeline open all the time.

  • Relay

Spring Reactor

The reactive stream API implementation of Spring.

• Creating

• Combining

• Transforming

• Filtering

• Async

Akka

Implementation of Akka patterns using Akka typed, using Java DSL.

• patterns

Akka Stream

The reactive stream API implementation of Akka.

• Source, Flow, Sink
• Subscriber
• Back-pressure
• GraphDSL

RSocket

Binary protocol for use on byte stream transports.

• Fire and Forget
• Request Response
• Request Stream
• Request Channel

Quarkus

Example of most important features of the red hat framework.

• features

Micronaut

A modern, JVM-based, full-stack framework for building modular, easily testable microservice and serverless applications.

• features

Oracle Helidon

Helidon is a collection of Java libraries for writing microservices that run on a fast web core powered by Netty.

• WebClient / WebServer
• Reactive Messaging
• Kafka connector
• Scheduler

Example of most important features of this functional programing library for Java.

• effects
• Functions
• Collections
• Pattern matching
• Future

Category Theory

Example of Monad implementation for Java.

• monad

Apache Curator is a Java/JVM client library for Apache ZooKeeper, a distributed coordination service.

• distributed lock and counter

Reactive Stream Monads combination

A Combination of Monads that implement Reactive Stream.

• ReactiveStream

Observer V Iterator Pattern

An explanation, comparative and benchmark between these two patterns.

• ObserverVsIterator

RxJava V Spring Reactor

A Comparative and benchmark between these two frameworks.

• ReactorVsRx

Java 8

• Stream
• Functions
• CompletableFuture

Java 9

• Flow
• Features
• Optional
• Module system

Java 10

• Collections
• Local variable type inference

Java 11

• HttpClient2
• String
• File
• Collection
• Local variable

Java 12

• Switch Expression
• String API
• JVM Constants API

Java 14

• Pattern matching
• Multiline text
• Record type

Java 15

• Sealed class

Java 16

• Features

Java 17

• Features

Java 18

Project Loom feature

• Features

Java 19

Pattern matching improvements & Virtual Thread

• Features

Eclipse Collections is one of the best Java collections framework ever that brings happiness to your Java development.

• feature

Examples of patterns using Apache Kafka.

• Throttling
• Assign
• Stream
• balancing
• Sagas
• Delay
• AdminClient

Software craftsmanship

• (S)ingle responsibility principle
• (O)pen/Closed principle
• (L)iskov substitution principle
• (I)nterface segregation principle
• (D)on't repeat yourself

Programs

• PaymentAPI: A Reactive microservice with DDD + CQRS + Event Sourcing
• Reactive StarWars A Star wars reactive microservice platform, formed by four services