RxJava и Retrofit2: android.os.NetworkOnMainThreadException

Question

Я пытаюсь объединить несколько запросов в Observable.zip (...), но у меня возникла ошибка android.os.NetworkOnMainThreadException. Что я делаю неправильно?

Call<EmployeeInfo> companyInfo = apiService.employee(); 
    companyInfo.enqueue(new Callback<EmployeeInfo>() { 
     @Override 
     public void onResponse(Call<EmployeeInfo> call, Response<EmployeeInfo> response) { 
      EmployeeInfo info = response.body(); 
      Observable.zip(
        apiService.getOrders("https://exaple.com"), 
        apiService.getOrders("https://exaple.com"), 
        apiService.getOrders("https://exaple.com"), 
        apiService.companyInfo("1"), new Func4<Orders, Orders, Orders, CompanyInfo, OrdersDataWrapper>() { 
         @Override 
         public OrdersDataWrapper call(Orders currentOrders, Orders waitingOrders, Orders enterOrders, CompanyInfo companyInfo) { 
          OrdersDataWrapper data = new OrdersDataWrapper(); 
          return data; 
         } 
        }).onErrorReturn(new Func1<Throwable, OrdersDataWrapper>() { 
       @Override 
       public OrdersDataWrapper call(Throwable throwable) { 
        return null; 
       } 
      }) 
        .observeOn(AndroidSchedulers.mainThread()) 
        .subscribe(new Action1<OrdersDataWrapper>() { 
         @Override 
         public void call(OrdersDataWrapper alDataWrapper) { 
         } 
        }); 
     } 

     @Override 
     public void onFailure(Call<EmployeeInfo> call, Throwable t) { 
     } 
    }); 

Answer 1

Вы устанавливаете .observeOn, но не в .subscribeOn, так RxJava подписывается и наблюдения в основном потоке. Добавьте .subscribeOn (Schedulers.io()), чтобы вызовы выполнялись в фоновом потоке.