Samples for RxJava 2.0 and RxKotlin
This is a collection of samples demonstrating the use of operators in RxJava 2.0 and RxKotlin.
To contribute, please check the wiki
Here's the list of operators that have been finished
Creating observables
| Operator | RxJava 2.x | RxKotlin |
|---|---|---|
| Create | create, generate, unsafeCreate | create |
| Defer | defer | defer |
| Empty/Never/Throw | empty, never, error | empty, never , error |
| From | from | from |
| Interval | interval | interval |
| Just | just | |
| Range | range | |
| Repeat | repeat | |
| Timer | timer | timer |
Transforming observables
| Operator | RxJava 2.x | RxKotlin |
|---|---|---|
| Map | map | map |
| Buffer | buffer | |
| FlatMap | concatMap flatMap switchMap | |
| GroupBy | groupBy |
Filtering observables
TODO
Combining observables
TODO
Error handling operators
TODO
Observable utility operators
| Operator | RxJava 2.x | RxKotlin |
|---|---|---|
| Delay | delay, delaySubscription | delay, delaySubscription |
| Timestamp | timestamp | timestamp |
| SubscribeOn | subscribeOn | subscribeOn |
| ObserveOn | observeOn | observeOn |
Conditional and boolean operators
TODO
Mathematical and Aggregate operators
TODO
Backpressure operators
TODO
Connectable obserable operators
TODO
Operators to convert observables
TODO