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:

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

• map, flatmap etc...

• filter, skip, take,

• scan

• amb, combineLast, zip, merge, concat

• takeUntil, takeWhile, skipUntil, skipWhile