Как сделать несколько сетевых вызовов одновременно, используя RxJava2 + Retrofit2

Question

Я получаю данные с сервера, используя несколько вызовов API, для этого я использую Retrofit @ и RxJava2.В моем классе обслуживания API у меня есть 2 запроса get, и они оба выполняются отдельно, из-за чего данные не поступают вообще. Я хочу получить все данные вместе из обоих apis. В настоящее время я получаю данные примерно так, и мне нужен лучший подход для обработки нескольких вызовов API.

Ниже мой код:

ApiService.class

public interface ApiService {

@GET("Categoery_api")
Observable<List<MenuModel>> getData();

@GET("Recent_six_post_api")
Observable<List<FlashStoryModel>> getFlashStory();

}

MainActivity. java

 private void getMenu(){

    Retrofit retrofit = RetrofitClient.getInstance();
    ApiService myApi = retrofit.create(ApiService.class);

    myApi.getData().subscribeOn(Schedulers.io())
                   .observeOn(AndroidSchedulers.mainThread())
                   .subscribe(new Observer<List<MenuModel>>() {
                       @Override
                       public void onSubscribe(Disposable d) {

                       }

                       @Override
                       public void onNext(List<MenuModel> menuModels) {

                           if(menuModels.size() > 0){

                               menuProg.setVisibility(View.INVISIBLE);
                               list.addAll(menuModels);

                               adapter = new MenuAdapter(list,getApplicationContext());
                               menuRecycler.setAdapter(adapter);
                           }
                       }

                       @Override
                       public void onError(Throwable e) {

                           menuProg.setVisibility(View.INVISIBLE);
                           Toast.makeText(getApplicationContext(),e.getMessage(),Toast.LENGTH_SHORT).show();
                       }

                       @Override
                       public void onComplete() {

                       }
                   });
}

private void getFlashStory(){

    Retrofit retrofit = RetrofitClient.getInstance();
    ApiService apiService = retrofit.create(ApiService.class);
    apiService.getFlashStory().subscribeOn(Schedulers.io())
                              .observeOn(AndroidSchedulers.mainThread())
                              .subscribe(new Observer<List<FlashStoryModel>>() {
                                  @Override
                                  public void onSubscribe(Disposable d) {

                                  }

                                  @Override
                                  public void onNext(List<FlashStoryModel> flashStoryModels) {

                                      if(flashStoryModels.size() > 0){

                                          prog1.setVisibility(View.INVISIBLE);

                                          storyList.addAll(flashStoryModels);
                                          flashStoryAdapter = new FlashStoryAdapter(getActivity(),storyList);
                                          flashStory.setAdapter(flashStoryAdapter);

                                          final Handler handler = new Handler();
                                          final Runnable update = new Runnable() {
                                              @Override
                                              public void run() {
                                                  if (currentPage == 6) {
                                                      currentPage = 0;
                                                  }
                                                  flashStory.setCurrentItem(currentPage++, true);
                                              }
                                          };

                                          timer = new Timer(); // This will create a new Thread
                                          timer.schedule(new TimerTask() { // task to be scheduled
                                              @Override
                                              public void run() {
                                                  handler.post(update);
                                              }
                                          }, DELAY_MS, PERIOD_MS);

                                      }
                                  }

                                  @Override
                                  public void onError(Throwable e) {

                                      prog1.setVisibility(View.INVISIBLE);
                                      Toast.makeText(getActivity(),e.getMessage(),Toast.LENGTH_SHORT).show();
                                  }

                                  @Override
                                  public void onComplete() {

                                  }
                              });
}

Кто-то, пожалуйста, дайте мне знать, как я могу достичь желаемого результата. Любой будет признательна за помощь.

СПАСИБО

Answer 1

Использование Observable.zip(...)

Observable.zip(
    apiService.getFlashStory(),
    apiService.getData(),
    BiFunction< List<FlashStoryModel>, List<MenuModel>, Unit> { r1, r2, _ ->
        // r1 is result from apiService.getFlashStory()
        // r2 is result from apiService.getData()

        // Do something here.

        // For example, this is what your code do above for apiService.getData()
        if(r2.size() > 0){
            menuProg.setVisibility(View.INVISIBLE);
            list.addAll(r2);

            adapter = new MenuAdapter(list,getApplicationContext());
            menuRecycler.setAdapter(adapter);
        }

    }

).subscribeOn(Schedulers.io()).observeOn(AndroidSchedulers.mainThread())

Это настоящая бифункция.

object: BiFunction<P, Q, R> {
    override fun apply(t1: P, t2: Q): R {
        TODO("not implemented") //To change body of created functions use File | Settings | File Templates.
    }
}

Но я пишу это как.

BiFunction<P, Q, R> { r1, r2, returnValue -> 
    TODO("not implemented") //To change body of created functions use File | Settings | File Templates.
}

Answer 2

Вы можете звонить одновременно, но с началом нового потока. Не используйте основной поток для этой цели. myApi.getData().subscribeOn(Schedulers.newThread()) .observeOn(Schedulers.newThread())

таким образом вы можете избежать зависания приложения или избежать отставания.