Reactive State 2

Reactive State.java

disposables.add(RxView.clicks(submitView)
  .map(ignored -> new SubmitEvent(nameView.getText().toString()))
  .doOnNext(ignored -> {
    submitView.setEnabled(false);
    progressView.setVisibility(VISIBLE);
  })
  .flatMap(event -> service.setName(event.name))
  .observeOn(AndroidSchedulers.mainThread())
  .doOnNext(ignored -> progressView.setVisibility(GONE))
  .subscribe(s -> finish(), t -> {
    submitView.setEnabled(true);
    Toast.makeText(this, "Failed to set name: " + t.getMessage(), LENGTH_SHORT).show();
  }));