Party tricks with RxJava, RxAndroid & Retrolambda

All the cool kids are doing it, why aren’t you?

César Ferreira
Aug 26, 2015 · 3 min read

Users expect real time data. They want their tweets now. Their order confirmed now. As a developer, you demand fire-and-forget messaging. You really don’t want to be blocked waiting for a result… You want to have the result pushed to you when it is ready, whenever that is. Even better, when working with big result sets, you want to receive individual results as they are ready because you don’t want to wait for the entire set to be processed before you see the first item on that list. Developers have lots of tools to push data, that’s easy. Developers need tools to react to pushed data.

Let there be light… even better… Reactive Extensions!

Described as “a library for composing asynchronous and event-based programs by using observable sequences” it is very well suited for introducing and managing concurrency for the purpose of offloading. That is, performing a given set of work concurrently to free up the current thread (usually the UI thread). A very popular use of this is to maintain a responsive UI, which is essential for a great mobile user experience!

I’ve been assembling a few usage examples as I learn how to use them in the last couple of months and I’ve decided to share them…

Just remember:

The basic building blocks of reactive code are Observables and Subscribers. An Observable emits items; a Subscriber consumes those items.

Import your dependencies:

…and configure retrolambda:

UPDATE: I’ve written a small tutorial about a super easy way to configure retrolambda

Fire up your IDE and let’s try’em out!

Some people assume that, because RxJava is all about “asynchronous sequences”, everything will happen on different threads by default, but that’s not the case so don’t forget to define both .observeOn() and .subscribeOn(). The first defines the thread in which the Observer will be subscribed (thread where the data will be received upon completion) and the latter produces a new Observable which will cause your subscription to occur on a thread retrieved from the specified scheduler instead of the thread from which subscribe() is called (android’s main thread, the UI thread).

Bonus: Retrofit

… + RxJava + RxAndroid + Retrolambda

Let’s see them all in action:

Pretty sweet right?

Here’s a few extra links with cool information:

If you have suggestions you want to see added ask away or create a pull request to this gist

Hit me up on @cesarmcferreira if you have any questions☺

Published in Startups, Wanderlust, and Life Hacking


The Startup

Get smarter at building your thing. Join The Startup’s +724K followers.

Medium is an open platform where 170 million readers come to find insightful and dynamic thinking. Here, expert and undiscovered voices alike dive into the heart of any topic and bring new ideas to the surface. Learn more

Follow the writers, publications, and topics that matter to you, and you’ll see them on your homepage and in your inbox. Explore

If you have a story to tell, knowledge to share, or a perspective to offer — welcome home. It’s easy and free to post your thinking on any topic. Write on Medium

Get the Medium app

A button that says 'Download on the App Store', and if clicked it will lead you to the iOS App store
A button that says 'Get it on, Google Play', and if clicked it will lead you to the Google Play store