Android RxJava+Retrofit 一次(合併)請求多個介面
阿新 • • 發佈:2019-01-29
在實際開發中,我們需要同時請求2個或者2個以上的介面,同時又有更新UI,怎麼辦呢?
最直接的最暴力的方法就是直接在一個方法裡同步呼叫兩個介面,那使用RxJava怎麼實現呢?
這個問題可以使用RxJava的Merge操作符實現,故名思議就是將兩個介面Observable合成一個,廢話不說直接上程式碼:
@Override
public void getPlaceAndWeatherData(String place) {
mMainView.showProgress();
PlaceRepository repository = new PlaceRepository();
Context context = BaseApplication.getInstance();
Observable placeObservable = repository.getPlaceList(context);
Observable weatherObservable = ServiceManager.getInstance().getApiService().getWeatherInfo(place, Constants.BAIDU_AK);
Observable.merge(placeObservable, weatherObservable)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Subscriber<Object>() {
@Override
public void onCompleted() {
mMainView.hideProgress();
}
@Override
public void onError(Throwable e) {
mLogger.error(e.getMessage(), e);
mMainView.hideProgress();
}
@Override
public void onNext(Object obj) {
if (obj instanceof List) {
mMainView.setupPlaceData((List<Place>) obj);
} else if (obj instanceof WeatherResponse) {
mMainView.setupWeatherData((WeatherResponse) obj);
}
}
});
}
這樣就很巧妙的解決了前面的問題。
如果這樣的程式碼看著還不舒服,你完全可以使用Lambda,這樣可以讓程式碼看起來少之又少,不過Android studio目前還不支援Lambda,如果想要使用請安裝外掛RetroLambda 並且JDK 使用JDK 8以上版本.