Learning RxJava 2 for Android by example

This project is for :

who is migrating to RxJava 2
or just started with RxJava.

About me

Hi, I am Amit Shekhar, Co-Founder @ Outcome School • IIT 2010-14 • I have taught and mentored many developers, and their efforts landed them high-paying tech jobs, helped many tech companies in solving their unique problems, and created many open-source libraries being used by top companies. I am passionate about sharing knowledge through open-source, blogs, and videos.

You can connect with me on:

Join Outcome School and get high paying tech job: Outcome School

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.

Using RxJava 2.0 Library in your application

Add this in your build.gradle

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

If you are using RxAndroid also, then add the following

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

RxJava 2 Operators Examples present in this sample project:

Map -> transform the items emitted by an Observable by applying a function to each item. Blog: RxJava Operator Map vs FlatMap
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
FlatMap -> transform the items emitted by an Observable into Observables, then flatten the emissions from those into a single Observable. Blog: RxJava Operator Map vs FlatMap
Take -> emit only the first n items emitted by an Observable. Blog for reference
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
Concat -> emit the emissions from two or more Observables without interleaving them. Blog for reference
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
SwitchMap -> transform the items emitted by an Observable into Observables, and mirror those items emitted by the most-recently transformed Observable

Highlights of the examples :

DisposableExampleActivity - Using CompositeDisposable. Blog for reference
FlowableExampleActivity - Using Flowable and reduce operator
SingleObserverExampleActivity - Using SingleObserver
CompletableObserverActivity - Using CompletableObserver
MapExampleActivity - Using map Operator. Blog: RxJava Operator Map vs FlatMap
ZipExampleActivity - Using zip Operator
BufferExampleActivity - Using buffer Operator
TakeExampleActivity - Using take Operator. Blog for reference
ReduceExampleActivity - Using reduce Operator
FilterExampleActivity - Using filter Operator
SkipExampleActivity - Using skip Operator
ReplayExampleActivity - Using replay Operator
ConcatExampleActivity - Using concat Operator. Blog for reference
MergeExampleActivity - Using merge Operator
DeferExampleActivity - Using defer Observable
SwitchMapExampleActivity - Using switchMap Observable
IntervalExampleActivity - Using Interval. Blog for reference
RxBusActivity - RxBus, RxJava2Bus, EventBus, RxEventBus
PaginationActivity - Pagination for loadMore in RecyclerView. Blog: Pagination In RecyclerView Using RxJava Operators
ComposeOperatorExampleActivity - Compose operator for reusable
Search Implementation - Using debounce, switchMap, distinctUntilChanged
Implement Caching Using RxJava Operators - Using concat, firstElement
PublishSubjectExampleActivity. Blog: RxJava Subject - Publish, Replay, Behavior, and Async

Find this project useful ? ❤️

Support it by clicking the ⭐ button on the upper right of this page. ✌️

Thanks

Amit Shekhar
Co-Founder @ Outcome School