Ответ 1
Вот как вы можете решить проблему выше, то есть получать данные из двух источников (локальных и удаленных) и отправлять обновление в интерфейс только тогда, когда это необходимо.
Класс данных обертывает ваши данные и также сохраняет источник данных
class Data<T> {
static final int STATE_LOCAL = 0;
static final int STATE_SERVER = 1;
private T data;
private int state;
Data(T data, int state) {
this.data = data;
this.state = state;
}
public int getState() { return state; }
public T getData() { return data; }
}
...
public Observable<Model> getData(long id) {
// Used to cache data and compare it with server data, so we can avoid unnecessary UI updates
Subject<Data<Model>> publishSubject = BehaviorSubject.create();
publishSubject.onNext(new Data<>(null, Data.STATE_LOCAL));
Observable<Data<Model>> server = getRequest()
.map(items -> new Data<>(items, Data.STATE_SERVER))
// Here we are combining data from server and our `BehaviorSubject`
// If any one has ideas how to do this without the subject, I'll be glad to hear it.
.flatMap(items -> Observable.zip(publishSubject.take(1), Observable.just(items), Pair::new))
.flatMap(oldNewPair -> {
// Here we are comparing old and new data to see if there was any new data returned from server
Data<Model> prevData = oldNewPair.first;
Data<Model> newData = oldNewPair.second;
//Could be any condition to compare the old and new data
if (prevData.data != null && prevData.data.updated_at() == newData.data.updated_at())
return Observable.just(prevData);
else
return database.insert(tableName(), contentValues(newData));
return getFromDb(id)
.map(item -> new Data<>(item, Data.STATE_LOCAL))
.onErrorResumeNext(server)
.doOnNext(item -> {
publishSubject.onNext(item);
if (item.getState() == Data.STATE_LOCAL)
server.subscribeOn(Schedulers.io()).observeOn(Schedulers.io()).subscribe();
})
.map(item -> item.data);
}
Это решение не использует amb
и использует BehaviorSubject, который решает следующую проблему:
-
Использование
delaySubscription
(ранее использовалось для предотвращения раннего отказа в случае отсутствия Интернета.) -
Ранее, каждый раз, когда на сервер решались два вызова, которые решаются в этом случае.