RxJava 2 for Android by Samples

How to use RxJava 2.x in your application

Add this in your build.gradle

compile 'io.reactivex.rxjava2:rxjava:2.1.3'

Don't forget to add RxAndroid also

compile 'io.reactivex.rxjava2:rxandroid:2.0.1'

I'm also using Retrofit, so add the following

compile 'com.squareup.retrofit2:retrofit:2.3.0'

What RxJava 2.x differs from RxJava 1.x

RxJava 1.x	RxJava 2.x
About backpressure	About backpressure
when create Observable, callback Observable.onSubscribe()	when create Observable, callback ObservableEmitter<> and directly throws Exception
when create Observer, callback onNext(),onError(),onCompleted(), useSubscription	when create Observer, callback onNext(),onError(),onComplete(),onSubscribe(), use Disposable
To simplify subscribe, Fun1, Fun2, Actio1, Action2	To simplify subscribe, Function, BiFunction, Consumer, BiConsumer

Operators :

• Interval —> create an Observable that emits a sequence of integers spaced by a particular time interval
• Map -> transform the items emitted by an Observable by applying a function to each item
• FlatMap -> transform the items emitted by an Observable into Observables, then flatten the emissions from those into a single Observable
• Concat -> emit the emissions from two or more Observables without interleaving them
• Zip -> combine the emissions of multiple Observables together via a specified function and emit single items for each combination based on the results of this function
• Filter -> emit only those items from an Observable that pass a predicate test
• Take -> emit only the first n items emitted by an Observable
• Reduce -> apply a function to each item emitted by an Observable, sequentially, and emit the final value
• Skip -> suppress the first n items emitted by an Observable
• Buffer -> periodically gather items emitted by an Observable into bundles and emit these bundles rather than emitting the items one at a time
• Replay -> ensure that all observers see the same sequence of emitted items, even if they subscribe after the Observable has begun emitting items
• Merge -> combine multiple Observables into one by merging their emissions

Examples present in this project

• RxConcatActivity -> Use Concat operator combined with Retrofit2
• RxDisposableActivity -> Use CompositeDisposable
• RxFlatMapActivity -> Use FlatMap operator and From operator
• RxMapActivity -> Use Map operator
• RxFlowableActivity -> Use Flowable operator