Gain insights into RxJava's principles, explore its integration into Android, and discover why it’s the leading reactive library for enhanced app development.

Reactive Programming on Android with RxJava_468 x 60 copy 2.png

tarball.tar.gz

RxJava

Since its inception in 2012, RxJava has slowly gained in popularity for enabling reactive programming on Android. It is now deemed as the go-to and leading reactive library. Many companies have adopted the reactive way of programming, including Google, with its release of Android Architecture Components, which has many reactive elements in its design.

In this course, you will learn the fundamental principles of RxJava which will serve as a foundation for experienced Android developers who are new to the library and want to start integrating it into their apps.

Reactive Programming with RxJava

As we can see, using `.subscribeOn()` and `.observeOn()` makes threading easy, but there are some intricacies to these operators that need to be discussed.


# `.subscribeOn()`

As pointed out earlier, it doesn’t matter where the `.subscribeOn()` call appears in the operator chain. However, it’s important to note that only the first `.subscribeOn()` call is applied. Any subsequent `.subscribeOn()` calls will have no effect. Oftentimes, `Observable` objects are created as part of a library or API and provided to a client via an interface. This interface documentation should clearly state if the returned `Observable` will have already been relegated to some `Scheduler` via `.subscribeOn()` because, if it has, the client will no longer be able to make its own `.subscribeOn()` call.

> Remember: Only the first `.subscribeOn()` call, no matter where it is in the operator chain, is applied to the source `Observable` at the time the  `.subscribe()` operator is called. Any subsequent `.subscribeOn()` calls will have no effect.

Getting Started

Part 1: RxJava Basics

Reactive Programming

RxJava Core Components

Operators

Multithreading

Part 2: RxJava Advanced

Reactive Modeling on Android

Backpressure

Error Handling

Conclusion

Scheduler Behavior

`.subscribeOn()`