Being Reactive 1

Being Reactive.java

// onCreate
disposables.add(um.getUser()
 .observeOn(AndroidSchedulers.mainThread())
 .subscribeWith(new DisposableObserver<User>() {
   @Override public void onNext(User user) {
     tv.setText(user.toString());
   }
   @Override public void onComplete() { /* ignored */ }
   @Override public void onError(Throwable t) { /* crash or show */ }
 }));

// onDestroy
disposables.dispose();

// button click listener
disposables.add(um.setName("Jane Doe")
 .subscribeOn(Schedulers.io())
 .observeOn(AndroidSchedulers.mainThread())
 .subscribeWith(new DisposableCompletableObserver() {
   @Override public void onComplete() {
     // success! re-enable editing
   }
   @Override public void onError(Throwable t) {
     // retry or show
   }
 })