viewmodel.java

public class MovieDetailViewModel extends BaseViewModel {

    LiveData<MovieDetailViewState> baz = new MutableLiveData();
    MutableLiveData<Void> retryNetworkRequest = new MutableLiveData();

    MovieInteractor movieInteractor;

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

    LiveData<MovieDetailViewState> getViewState() {
        baz = Transformations.switchMap(retryNetworkRequest,(v)->{
            return LiveDataReactiveStreams.fromPublisher(movieInteractor.getMovieByID("1")
                    .map((it)->(MovieDetailViewState) new MovieDetailViewState.Data(it))
                    .onErrorReturnItem(new MovieDetailViewState.Error(""))
                    .startWith(new MovieDetailViewState.Loading()));
        });

        return baz;
    }

    void retryNetwork() {
        retryNetworkRequest.setValue(null);
    }


}

public class MovieDetailViewModel extends BaseViewModel {

    LiveData<MovieDetailViewState> baz =  Transformations.switchMap(retryNetworkRequest,(v)->{
            return LiveDataReactiveStreams.fromPublisher(movieInteractor.getMovieByID("1")
                    .map((it)->(MovieDetailViewState) new MovieDetailViewState.Data(it))
                    .onErrorReturnItem(new MovieDetailViewState.Error(""))
                    .startWith(new MovieDetailViewState.Loading()));
        });

    MutableLiveData<Void> retryNetworkRequest = new MutableLiveData();

    MovieInteractor movieInteractor;

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

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

    void retryNetwork() {
        retryNetworkRequest.setValue(null);
    }
}