MovieRepository.java

public class MovieRepository extends BaseRepository {

    private MovieApi movieApi;
    private MovieDatabaseHelper movieDatabaseHelper;

    public MovieRepository(Context context) {
        movieApi = getRetrofitHelper().getService(MovieApi.class);
        movieDatabaseHelper = new MovieDatabaseHelper(context);
    }

    public LiveData<List<Movie>> getMovies() {
        Single<Response<SearchResult>> resultObservable = movieApi.getMovieList();
        resultObservable.subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread()).subscribe(searchResult -> {
            if (!searchResult.isSuccessful()) {
                Log.i("Repository", "not respond");
            } else {
                movieDatabaseHelper.save(searchResult.body().getSearch());
            }
        }, throwable -> Log.i("Repository", throwable.getMessage()));

        return movieDatabaseHelper.getAll();
    }
}