RxJava usage samples

Requests sequence

public class SignUpScreen extends BaseFragment{
  
  private void signUp(RegistrationInfo regInfo) {
    startProgressAnimation();
    bind(api.registerWith(regInfo)))
        .flatMap(registerResponse -> api.getToken("password", userName, password, Consts.CLIENT_ID, Consts.CLIENT_SECRET))
        .flatMap(token -> {
            User.saveTokens(token);
            return api.getProfileInfo(Consts.SELF);
        })
        .subscribeOn(Schedulers.io())
        .doOnTerminate(() -> stopProgressAnimation())
        .subscribe(profile -> {
          registerPushNotification();
          openStatusScreen();
        }, Errors.onError(getActivity()));
  }
  
}

Turn off gps

public class App extends Application {
  Subject<Void, Void> activityVisibleEvent = PublishSubject.create();
  
  public void activityVisible() {
    activityVisibleEvent.onNext(null);
    if (serviceNotRunning()) {
      startGpsService();
    }
  }
  
  public void activityGone() {
    Observable.timer(10, TimeUnit.SECONDS)
        .takeUntil(activityVisibleEvent)
        .subscribe(t -> stopGpsService(), Errors.logHandler());
  }
  

}

Wait for 2 and more events

public SomeClass extends BaseFragment {
  
  public void onCreate(Bundle savedInstanceState) {
    Observable.combineLatest(geoServiceConnected, needDataLoading, categoryRetrieved,
      (t, t1, t2) -> null)
      .takeUntil(viewDestroyed)
      .take(1)
      .subscribe(t -> fetchStatuses(null, setAdapter()));
  }
    
}