Оптимизированный кэш и сетевой метод takeUntil с помощью Retrofit, RxJava и Gson

Я пытаюсь реализовать оптимизированный кеш и сетевой метод, используя оператор RxJava takeUntil для получения данных с сервера. Я использую модель Gson для анализа ответов JSON от API.

Я застреваю при получении данных с сервера из-за использования модели Gson. поскольку возвращаемый тип не соответствует как для Netwrok Request, так и для Disk cache.

Я тестировал несколько методов, но не смог сделать это правильно.

ApiService.java

@GET(ApiConstants.GET_QUESTIONS_URL) Observable<RequestResponse> getQuestions();

ineteractor.java

   public void performGetElQuestions(String query, QuestionsRequestServerCallback callback) {

 getFreshNetworkData()//
        .publish(network ->//
            Observable.merge(network,//
                getCachedDiskData().takeUntil(network)))
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new DisposableObserver<Question>() {
          @Override
          public void onComplete() {
            callback.onQuestionsReady(mQuestionsList);
          }
          @Override
          public void onError(Throwable e) {
            callback.onQuestionsFailed();
          }

          @Override
          public void onNext(Question question) {
            // mQuestionsList is an arraylist
            mQuestionsList.add(question);
          }
        });

interactor.java

private Observable<Question> getFreshNetworkData() {
        return apiService.getQuestions()
              .flatMap(Observable::fromIterable)
              .doOnSubscribe((data) -> new Handler(Looper.getMainLooper())//
                    .post(() -> adapterSubscriptionInfo.add("(network) subscribed")))//
              .doOnComplete(() -> new Handler(Looper.getMainLooper())//
                    .post(() -> adapterSubscriptionInfo.add("(network) completed")));
    }

Кэшированные данные

     private Observable<Question> getCachedDiskData() {
    List<Question> list = new ArrayList<>();
    //get cached data from SQLite or disk

    return Observable.fromIterable(list)//
        .doOnSubscribe((data) -> new Handler(Looper.getMainLooper())//
            .post(() -> Timber.d("(disk) cache subscribed")))//
        .doOnComplete(() -> new Handler(Looper.getMainLooper())//
            .post(() -> Timber.d("(disk) cache completed")));
  }

Парсер модели Gson

RequestResponse.java

Public class RequestResponse {

    @SerializedName("questions")
    ArrayList<Question> questions;

    public ArrayList<Question> getQuestions() {
        return questions;
    }
}

Спасибо :) .


android rx-java2 gson retrofit rx-java
person Mohamed ALOUANE    schedule 03.12.2016    source источник
comment
Какой json вы получаете с сервера?   -  person iagreen    schedule 04.12.2016
comment
Привет, @iagreen!   -  person Mohamed ALOUANE    schedule 04.12.2016
comment
Пожалуйста, покажите трассировку стека ошибки   -  person Maksim Ostrovidov    schedule 05.12.2016

Ответы (1)


arrow_upward
0
arrow_downward

Я использую область и использую преимущества RXJava concat + take (1), каждый раз, когда я извлекаю данные и кэширую их, но если интернет-соединение медленное, кэшированные данные всегда готовы. Пример кода для объекта Country:

 public Observable<ArrayList<Pair<Country,City>>> queryAllAndCopyOrLoad(){
    return Observable.concat(

        Observable.just(storageInteractor.queryAllAndCopySync(Country.class))
            .filter(RxPretty::notEmpty)
            .subscribeOn(AndroidSchedulers.mainThread()),

        networkService.serverApi()
            .getCountries()
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .doOnNext(countries -> storageInteractor.deleteAllAndPut(countries, Country.class))
            .doOnNext(countries -> firstTime = false))

        .take(1)
        .flatMap(this::transformToCityCountryPair);
  }
person Mykola Tychyna    schedule 23.12.2016