Reactive State 5

Reactive State.java

Observable<SubmitEvent> events = RxView.clicks(submitView)
  .map(ignored -> new SubmitEvent(nameView.getText().toString()));

Observable<SubmitUiModel> models = events
  .flatMap(event -> service.setName(event.name)
  .map(response -> SubmitUiModel.success())
  .onErrorReturn(t -> SubmitUiModel.failure(t.getMessage()))
  .observeOn(AndroidSchedulers.mainThread())
  .startWith(SubmitUiModel.inProgress()));

disposables.add(models.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); }));