viewmodelRx.java

public class MovieDetailViewModel extends BaseViewModel {

    PublishProcessor<Boolean> retryNetworkRequest = PublishProcessor.create();

    MovieInteractor movieInteractor;

    BehaviorProcessor<MovieDetailViewState> baz =  null;

    @Inject
    public MovieDetailViewModel(MovieInteractor movieInteractor) {
        this.movieInteractor = movieInteractor;

        baz =BehaviorProcessor.create();
        retryNetworkRequest
                .switchMap(aVoid -> movieInteractor.getMovieByID("1")
                        .map((it) -> (MovieDetailViewState) new MovieDetailViewState.Data(it))
                        .onErrorReturnItem(new MovieDetailViewState.Error(""))
                        .startWith(new MovieDetailViewState.Loading()))
                .subscribeWith(new MyDisposabObserver(baz));

    }

    BehaviorProcessor<MovieDetailViewState> getViewState() {
        return baz;
    }

    void retryNetwork() {
        retryNetworkRequest.onNext(false);
    }
}