1. 程式人生 > >Android RxJava+Retrofit 一次(合併)請求多個介面

Android RxJava+Retrofit 一次(合併)請求多個介面

在實際開發中,我們需要同時請求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以上版本.