Reactive State 4

Reactive State.java

disposables.add(RxView.clicks(submitView)
  .map(ignored -> new SubmitEvent(nameView.getText().toString()))
  .flatMap(event -> service.setName(event.name)
  .map(response -> SubmitUiModel.success())
  .onErrorReturn(t -> SubmitUiModel.failure(t.getMessage()))
  .observeOn(AndroidSchedulers.mainThread())
  .startWith(SubmitUiModel.inProgress()))
  .subscribe(model -> {
    submitView.setEnabled(!model.inProgress);
    progressView.setVisibility(model.inProgress ? VISIBLE : GONE);
    if (!model.inProgress) {
      if (model.success) finish()
      else Toast.makeText(this, "Failed to set name: " + model.errorMessage, LENGTH_SHORT).show();
    }
  }, t -> { throw new OnErrorNotImplementedException(t); }));