Reactive X - RxJava - Samples

This repository consists of samples on how to utilise RxJava to do reactive programming in Java.

The following simple topics to some advanced areas are covered:

Creating Observables

• basic observable creation using just, from, create
• subscriptions using subscribe and unsubscribe
• Hot & Cold observables (ConnectableObservables, Subjects)

Manipulation with Operators

Transformation

• map, flatmap etc...

Filtering

• filter, skip, take,

Accumalation

• scan

Combination

• amb, combineLast, zip, merge, concat

Conditionals

• takeUntil, takeWhile, skipUntil, skipWhile

Tackle errors

Concurrency and Parallelism