quangctkm9207 / mvp-android-arch-component Goto Github PK

public Flowable<List<Question>> loadQuestions(boolean forceRemote) {
Flowable<List<Question>> questions;
    if (forceRemote) {
      questions = remoteDataSource.loadQuestions(true).doOnEach(notification -> {
        // Save new data to local data source
        List<Question> list = notification.getValue();
        if (list != null && !list.isEmpty()) {
          saveDataToLocal(list);
        }
      });
    } else {
      questions = localDataSource.loadQuestions(false);
    }
    return questions;
  }

    override fun loadAll(forceRemote: Boolean): Flowable<List<Question>> {
        if (forceRemote){
            return loadFromRemote()
        } else {
            return localDataSource.loadAll(false)
                    .flatMap{ if (it.isEmpty()) Flowable.empty() else Flowable.fromArray(it) }
                    .switchIfEmpty(loadFromRemote())
        }
    }