alifruliarso / reactive

Examples related with the reactiveX API for Java

Author Pablo Perez Garcia

ReactiveX

Marble diagrams are not clear enough?.

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

This project it´s just a complement to play around and put in practice what I´ve learned in the platform.

To reference to the real documentation go here https://github.com/ReactiveX/RxJava/wiki

RxScala examples here

All the most common features of Observable

• Contactable

  

  • HotObservable

• Combining

  

  • Chain
  • Concat
  • Merge
  • Zip
  • Switch

• Creating

  

  • Create
  • Defer
  • Interval
  • Subscription

• Filtering

  

  • Debounce
  • Distinct
  • Skip
  • Take

• 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

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

The Java 8 Stream API with examples of most useful operators.

• Stream

The Java 8 Functions with particle examples of how to use it.

• Functions

Software craftsmanship

• (S)ingle responsibility principle

• (O)pen/Closed principle

• (L)iskov substitution principle

• (I)nterface segregation principle

• (D)on't repeat yourself