This is a Gradle-based Kotlin project in which I have summarized what I know about RxJava 2, from its basics to some advanced topics.
As of now this project consists of following packages:
- Creation: how to create Observables using
Observable.create(),Observable.from(), etc. - Subscription: how to consume Observables using various subscription methods available
- Operators: how to take advantage of operators like
Observable.filter(),Observable.map(),Observable.merge(), etc. to manipulate Observables - Flow control: how to control Observables that outperform their subscribers
- Backpressure: how to control Observables that outperform their subscribers (in a more advanced way)
- Error Handling: how to deal with errors when consuming an Observable
- Testing: how to use
TestObserverandTestSchedulerfor testing Observables