Search⌘ K
AI Features
Home
Courses
Reactive Programming with RxJava

RxJava in Action

Discover how to implement RxJava by following a step-by-step example that filters, transforms, and limits data streams on background and UI threads. Learn how each operator contributes to building reactive pipelines that handle asynchronous data efficiently and update the user interface.

We'll cover the following...

Sample RxJava code

Let’s take a look at some RxJava in action:

Java
Observable<Car> carsObservable = getBestSellingCarsObservable(); 
    carsObservable.subscribeOn(Schedulers.io())
    .filter(car -> car.type == Car.Type.ALL_ELECTRIC)
    .filter(car -> car.price < 90000)
    .map(car -> car.year + " " + car.make + " " + car.model)
    .distinct()
    .take(5)
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(this::updateUi);

The above code will get the top 5 sub-$90,000 electric cars and then update the UI with that data.

There’s a lot going ...