private void apiPlace(){
if (isOnline(App.getContext())){
DiskCache.clearAll();
Observable.intervalRange(10, 5, 1, 2, TimeUnit.SECONDS)
.map(integer -> integer * 10-90)
.doOnSubscribe(disposable1 -> getViewState().showProgress())
.doFinally(() -> getViewState().hideProgress())
.subscribeOn(Schedulers.io())
.subscribe(integer -> {
ApiRequest.getPlace(integer)
.observeOn(AndroidSchedulers.mainThread())
.subscribe(place -> {
getViewState().addMarkersOnMap(place);
DiskCache.savePlace(place);
});
},throwable -> {
Log.e("MainPresenter", throwable.getMessage() + "");
});
}else {
Observable.fromIterable(DiskCache.restorePlace())
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.doOnSubscribe(disposable1 -> getViewState().showProgress())
.doFinally(() -> getViewState().hideProgress())
.subscribe(place -> {
getViewState().addMarkersOnMap(place);
},throwable -> {
Log.e("MainPresenter", throwable.getMessage() + "");
});
}
}
RxJava начал изучать недавно. Но в принципе понял как все работает. Вот только я смотрю на этот код и понимаю что он ужасен. Очень много чего повторяющегося.
Может ли кто - нибудь оптимизировать код, это поможет мне очень сильно понять как правильно писать в будущем. Да и людям кто начинает думаю тоже придется столкнутся с многопоточносью и кодом подобно этому.
В кратце делается проверка на офлайн и онлайн режим. Если онлайн то делаем 5 запросов в интернет и получаем данные и отправляем в View. Если оффлайн то вытаксиеваем из БД данные и отправляем в View
subscribeOn
иobserveOn
можно объединить с помощьюcompose
.isOnline
не нужны.