politrons / Reactive

Author Pablo Perez 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 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

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

• effects
• Functions
• Collections

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 API, Functions and Promises with examples of how to use it.

• Stream
• Functions
• CompletableFuture

Java 9

The most important features with particle examples of how to use it.

• Flow
• Features
• Optional
• Module system

Java 10

The most important features with particle examples of how to use it.

• Collections
• Local variable type inference

Java 11

The most important features with particle examples of how to use it.

• HttpClient2
• String
• File
• Collection
• Local variable

Java 12

The most important features with particle examples of how to use it.

• Switch Expression
• String API
• JVM Constants API

Java 14

The most important features with particle examples of how to use it.

• Pattern matching
• Multiline text
• Record type

Java 15

The most important features with particle examples of how to use it.

• Sealed class

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