hybrid rx request

gistfile1.txt

/**
     * Осуществляет гибридный запрос, в методе происходит объединение данных приходящих с сервера и из кеша
     *
     * @param cacheRequest          запрос к кешу
     * @param networkRequestCreator функция, которая должна вернуть запрос к серверу,
     *                              Integer параметр этой функции определяет {@link QueryMode}
     * @param <T>                   тип возвращаемого значения
     */
    protected <T> Observable<T> hybridQuery(Observable<T> cacheRequest,
                                            Func1<Integer, Observable<T>> networkRequestCreator) {
        return cacheRequest
                .onErrorResumeNext(e -> {
                    Logger.e(e, "Error when getting data from cache");
                    return networkRequestCreator.call(QUERY_MODE_FORCE);
                })
                .flatMap(cache -> {
                    boolean cacheExist = cache != null;
                    @QueryMode int queryMode = cacheExist
                            ? QUERY_MODE_ONLY_IF_CHANGED
                            : QUERY_MODE_FORCE;
                    return Observable.concat(
                            cacheExist ? Observable.just(cache) : Observable.empty(),
                            networkRequestCreator.call(queryMode));
                });

    }