Learning RxJava 2 for Android by example
How to use RxJava 2 in Android Application
How to migrate from RxJava 1.0 to RxJava 2.0
This project is for :
- who is migrating to RxJava 2
- or just started with RxJava.
Just Build the project and start learning RxJava by examples.
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.
Migration From RxJava 1.0 to RxJava 2.0
To allow having RxJava 1 and RxJava 2 side-by-side, RxJava 2 is under the maven coordinates io.reactivex.rxjava2:rxjava:2.x.y and classes are accessible below io.reactivex.
Users switching from 1.x to 2.x have to re-organize their imports, but carefully.
Using RxJava 2.0 Library in your application
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 Examples present in this sample project
-
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
Quick Look on few changes done in RxJava2 over RxJava1
RxJava1 -> RxJava2
onCompleted
->onComplete
- without the trailing dFunc1
->Function
Func2
->BiFunction
CompositeSubscription
->CompositeDisposable
limit
operator has been removed - Usetake
in RxJava2- and much more.
Operators :
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
Highlights of the examples :
- DisposableExampleActivity - Using
CompositeDisposable
- FlowableExampleActivity - Using
Flowable
andreduce
operator - SingleObserverExampleActivity - Using
SingleObserver
- CompletableObserverActivity - Using
CompletableObserver
- MapExampleActivity - Using
map
Operator - ZipExampleActivity - Using
zip
Operator - BufferExampleActivity - Using
buffer
Operator - TakeExampleActivity - Using
take
Operator - ReduceExampleActivity - Using
reduce
Operator - FilterExampleActivity - Using
filter
Operator - SkipExampleActivity - Using
skip
Operator - ReplayExampleActivity - Using
replay
Operator - ConcatExampleActivity - Using
concat
Operator - MergeExampleActivity - Using
merge
Operator - DeferExampleActivity - Using
defer
Observable - IntervalExampleActivity - Using
Interval
- RxBusActivity - RxBus, RxJava2Bus, EventBus, RxEventBus
- PaginationActivity - Pagination for loadMore in RecyclerView
- ComposeOperatorExampleActivity - Compose operator for reusable
TODO
- Many examples are to be added
Find this project useful ? ❤️
- Support it by clicking the :star: button on the upper right of this page. :v:
Check out an awesome MVP architecture based project which uses RxJava2, Dagger2.
Check out an awesome library for fast and simple networking in Android.
Another awesome library for debugging databases and shared preferences.
Check out Mindorks awesome open source projects here
Contact - Let's become friend
License
Copyright (C) 2016 Amit Shekhar
Copyright (C) 2011 Android Open Source Project
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
Contributing to RxJava 2 Android Samples
Just make pull request. You are in!