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