Как использовать flatMap в Android RxJava для последовательного вызова трех веб-сервисов без использования лямбда-функции?

avatar
user2416657
8 апреля 2018 в 11:14
2045
1
6

Мой клиент 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);
    }

Как сделать так, чтобы веб-служба последовательно вызывала сначала getPoliticsArrayListObservable, а затем getEconomyArrayListObservable и getSportsArrayListObservable с использованием flatMap и без использования лямбда-функции?

Я пробовал что-то вроде этого:

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. Мы будем очень признательны за любую помощь.

Источник

Ответы (1)

avatar
hiten pannu
8 апреля 2018 в 11:25
2

Вы можете использовать оператор Concat RxJava для последовательного вызова API. Если вам не важна последовательность, вы можете использовать Zip.

Ну, я мог бы сделать что-то вроде этого. Вызовы API следует рассматривать как одиночные, если вы не поддерживаете с ними открытое соединение.

apiService.getDailyCounts()
          .flatMap { apiService.updateCounts() }
          .flatMap { apiService.changeTrialCourtCaseName() }
          .subscribeOn(Schedulers.io())
          .observeOn(AndroidSchedulers.mainThread())
          .subscribe()
user2416657
8 апреля 2018 в 11:28
0

Я использовал concat и слияние. Можем ли мы использовать для этого flatMap, если да, то как, если нет, то почему?