我使用改造(1.9)并试图找出我如何调用2 apis并合并结果.
我猜结果应该在最后一个api完成返回响应时合并…
我怎样才能做到这一点?
Udpate,根据Antons的回答我尝试了以下内容:
添加到gradle:
compile 'io.reactivex:rxjava:1.0.+'
compile 'io.reactivex:rxandroid:0.23.+'
Api界面
@GET("/maps/api/place/details/json")
Observable<PlaceDetailResult1> getPlacesFrom1( @Query("key") String key, @Query("placeid") String placeid);
@GET("api/places/{id}/ratings")
Observable<PlaceDetailResult2> getPlacesFrom2(@Path("id") String id);
在片段中
IPlaces api = adapter.create(IPlaces.class); //endpoint1
IPlaces api2 = adapter2.create(IPlaces.class); //endpoint2
Observable.combineLatest(
api.getPlacesFrom1("key", placeId),
api2.getPlacesFrom2(placeId),
new Func2<PlaceDetailResult1, PlaceDetailResult2, MergedReviews>() {
@Override
public MergedReviews call(PlaceDetailResult placeDetailResult1, PlaceDetailResult2 placeDetailResult2) {
// processToMerge( placeDetailResult1, placeDetailResult2)
return mr;
}
})
.subscribeOn(Schedulers.newThread())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Observer<MergedReviews>() {
@Override
public void onCompleted() {
}
@Override
public void one rror(Throwable e) {
}
@Override
public void onNext(MergedReviews mr) {
SetAdapter(mr.reviews);
SetPhotosAdapter(mr.photos);
}
});
有一件事值得注意,当我将RxJava添加到gradle时,我遇到了一些错误,在gradle文件中执行了multiDexEnabled后,该错误消失了
解决方法:
您可以使用RxJava并将结果组合如下:Combining API calls with RX Java
这是教程,如何使用RxJava和Retrofit 1.9:http://randomdotnext.com/retrofit-rxjava/