- who is migrating to RxJava 2
- or just started with RxJava.
RxJava 2.0 has been completely rewritten from scratch on top of the Reactive-Streams specification. The specification itself has evolved out of RxJava 1.x and provides a common baseline for reactive systems and libraries.
Because Reactive-Streams has a different architecture, it mandates changes to some well known RxJava types.
Add this in your build.gradle
compile 'io.reactivex.rxjava2:rxjava:2.0.6'
If you are using RxAndroid also, then add the following
compile 'io.reactivex.rxjava2:rxandroid:2.0.1'
-
RxJava 2.0 Example using
CompositeDisposable
asCompositeSubscription
andSubscription
have been removed. -
RxJava 2 Example using
Flowable
. -
RxJava 2 Example using
SingleObserver
,CompletableObserver
. -
RxJava 2 Example using RxJava2 operators such as
map, zip, take, reduce, flatMap, filter, buffer, skip, merge, concat, replay
, and much more: -
RxJava 2 Android Samples using
Function
asFunc1
has been removed. -
RxJava 2 Android Samples using
BiFunction
asFunc2
has been removed. -
And many others android examples
RxJava1 -> RxJava2
onCompleted
->onComplete
- without the trailing dFunc1
->Function
Func2
->BiFunction
CompositeSubscription
->CompositeDisposable
limit
operator has been removed - Usetake
in RxJava2- and much more.
com.rxjava2.android.samples.ui.operators
combining
AndTheWhenExampleActivity
CombineLatestExampleActivity
...
conditional
AllExampleActivity
SkipUntilExampleActivity
...
connectable
ConnectableExampleActivity
...
converting
ConvertingActivity
...
creating
CreateExampleActivity
DeferExampleActivity
FromExampleActivity
JustExampleActivity
...
errorhanding
CatchExampleActivity
RetryExampleActivity
...
filtering
FilterExampleActivity
DebounceExampleActivity
DistinctExampleActivity
...
mathematicalandaggregate
AverageExampleActivity
CountExampleActivity
MaxExampleActivity
ReduceExampleActivity
...
transforming
BufferExampleActivity
FlatMapExampleActivity
MapExampleActivity
GroupByExampleActivity
...
utility
DelayExampleActivity
TimeoutExampleActivity
...
Map
-> transform the items emitted by an Observable by applying a function to each itemZip
-> combine the emissions of multiple Observables together via a specified function and emit single items for each combination based on the results of this functionFilter
-> emit only those items from an Observable that pass a predicate testFlatMap
-> transform the items emitted by an Observable into Observables, then flatten the emissions from those into a single ObservableTake
-> emit only the first n items emitted by an ObservableReduce
-> apply a function to each item emitted by an Observable, sequentially, and emit the final valueSkip
-> suppress the first n items emitted by an ObservableBuffer
-> periodically gather items emitted by an Observable into bundles and emit these bundles rather than emitting the items one at a timeConcat
-> emit the emissions from two or more Observables without interleaving themReplay
-> ensure that all observers see the same sequence of emitted items, even if they subscribe after the Observable has begun emitting itemsMerge
-> combine multiple Observables into one by merging their emissions
- Many examples are to be added
Just make pull request. You are in!
=======