ac_repository_with_dao.java

@Singleton
public class PoisRepository {

    private final PoisDao mDao;
    private final WebService mWebService;
    private final AppExecutors mExecutors;

    private MutableLiveData<List<Poi>> mPois;

    @Inject
    public PoisRepository(PoisDao poisDao, WebService webService, AppExecutors executors) {
        this.mDao = poisDao;
        this.mWebService = webService;

        MutableLiveData<List<Poi>> mWebServerPois = new MutableLiveData<>();
        mWebService.getPois().enqueue((call, response) -> {
            mWebServerPois.setValue(response.body());
        });
        mWebServerPois.observeForever(newOnlineData -> mExecutors.diskIO().execute(() -> {
            if (newOnlineData != null) {
                mPoisDao.deletePois();
                mPoisDao.bulkInsertPois((ArrayList<Poi>) newOnlineData);
            }
        }
    }

    public LiveData<List<Poi>> getObservableAllPois() {
        return mPoisDao.getObservablePois();
    }

    public LiveData<Poi> getObservablePoi(String id) {
       return mPoisDao.getObservablePoi(id);
    }
}