tagged: android-rxjava

Android: RxJava BehaviorSubject

If you want to subcribe to something, and receive the last thing that was emitted, and then subscribe to further things, use BehaviorSubject:

BehaviorSubject<String> bs = BehaviorSubject.create();
bs.subscribe(value -> {
    Log.d("HIYA", "Found " + value);

It will print Found three and Found four only.

android-rxjava android

Android, RxJava and Retrofit: Wait for multiple network calls to finish

Say you have multiple network calls you need to make--cals to get Github user information and Github user events for example.
And you want to wait for each to return before updating the UI. RxJava can help you here.
Let's first define our Retrofit object to access Github's API, then setup two observables for the two network requests above:

Retrofit repo = new Retrofit.Builder()

Observable<JsonObject> userObservable = repo

Observable<JsonArray> eventsObservable = repo

The Retrofit interfaces are simple enough:

public interface GitHubUser {
  Observable<JsonObject> getUser(@Path("user") String user);

public interface GitHubEvents {
  Observable<JsonArray> listEvents(@Path("user") String user);

Lately we use RxJava's zip method to combine our two Observables and wait for them to complete before creating a new Observable.

Observable<UserAndEvents> combined = Observable.zip(userObservable, eventsObservable, new Func2<JsonObject, JsonArray, UserAndEvents>() {
  public UserAndEvents call(JsonObject jsonObject, JsonArray jsonElements) {
    return new UserAndEvents(jsonObject, jsonElements);

What's the UserAndEvents? It's just a simple POJO to combine the two objects:

public class UserAndEvents {
  public UserAndEvents(JsonObject user, JsonArray events) {
    this.events = events;
    this.user = user;
  public JsonArray events;
  public JsonObject user;

Finally let's call the subscribe method on our new combined Observable:

combined.subscribe(new Subscriber<UserAndEvents>() {
          public void onNext(UserAndEvents o) {
            // You can access the results of the 
            // two observabes via the POJO now

No more waiting in threads etc for network calls to finish. RxJava has done all that for you in zip().

android android-rxjava android-retrofit

Android: Retrofit 2.0 and RxJava

If you want to use all of the above buzzwords your code would look like the below.
Note I'm putting it all in one statement, for some mindless fun, rather than advocating such a practice, unless you really want to.

new Retrofit.Builder()
        .subscribeOn(Schedulers.newThread()) // Create a new Thread
        .observeOn(AndroidSchedulers.mainThread()) // Use the UI thread
        .subscribe(new Subscriber<User>() {
          @Override public void onCompleted() { }

          public void onError(Throwable e) {
            Log.d("HIYA", "An error!: " + e.getMessage());

          public void onNext(User user) {
            Log.d("HIYA", "So we've not got some text: " + user.avatar_url);

So we start by configuring retrofit, with the url, gson converster, RxJava adapter, and finally create and list the call, eventually subscribing to the Observable in a new thread, and observing it in the UI thread.
To ensure we return the an Observable, the interface is easy enough:

public interface GitHubService {
  Observable<User> listRepos(@Path("user") String user);

And the User is just a POJO with a public String called avatar_url.
Your gradle dependencies should look like this:

compile 'io.reactivex:rxjava:1.1.1'
compile 'io.reactivex:rxandroid:1.1.0'
compile 'com.squareup.retrofit2:retrofit:2.0.0-beta4'
compile 'com.squareup.retrofit2:converter-gson:2.0.0-beta4'
compile 'com.squareup.retrofit2:adapter-rxjava:2.0.0-beta'4

androd androd-retrofit android-rxjava

Page 1 of 1