我的 API 客户端
public class ApiClient {
public static final String BASE_URL = "http://baseurl.com/wp-json/";
private static Retrofit retrofit = null;
public static Retrofit getClient() {
if (retrofit==null) {
retrofit = new Retrofit.Builder()
.baseUrl(BASE_URL)
.addCallAdapterFactory(RxJava2CallAdapterFactory.create())
.addConverterFactory(GsonConverterFactory.create())
.build();
}
return retrofit;
}
}
我的端点接口
public interface ApiInterface {
@GET("posts/category/politics/recent-stories/")
Observable<ArrayList<ModelNewsPaged>> getPoliticsArrayListObservable(@Query("per_page") int perPage, @Query("page") int page);
@GET("posts/category/economy/recent-stories/")
Observable<ArrayList<ModelNewsPaged>> getEconomyArrayListObservable(@Query("per_page") int perPage, @Query("page") int page);
@GET("posts/category/sports/recent-stories/")
Observable<ArrayList<ModelNewsPaged>> getSportsArrayListObservable(@Query("per_page") int perPage, @Query("page") int page);
}
如何使用 flatMap & 而不使用 lambda 函数,使 Web 服务首先顺序调用 getPoliticsArrayListObservable,然后调用 getEconomyArrayListObservable 和 getSportsArrayListObservable?
我尝试过这样的事情:
final ApiInterface apiInterface = ApiClient.getClient().create(ApiInterface.class);
Observable.just(apiInterface)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.flatMap(new Function<ApiInterface, Observable<ArrayList<ModelNewsPaged>>>() {
@Override
public Observable<ArrayList<ModelNewsPaged>> apply(ApiInterface apiInterface) throws Exception {
return apiInterface.getPoliticsArrayListObservable(10,1);
}
})
.subscribe(new Observer<ArrayList<ModelNewsPaged>>() {
@Override
public void onSubscribe(Disposable d) {
}
@Override
public void onComplete() {
Log.d("flatMap", "onComplete");
}
@Override
public void onError(Throwable e) {
e.printStackTrace();
Log.d("flatMap", "onError");
}
@Override
public void onNext(ArrayList<ModelNewsPaged> integer) {
Log.d("flatMap", "Final result: " + integer.toString());
}
});
但这里的问题是,我无法链接更多的 flatMap 方法。任何帮助都感激不尽。