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()) 以便在后台线程上执行调用。