Being Reactive 3

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
   }
 }));