RxSearchView Switch threads exception .Online waiting for

Question

mSubscription = RxSearchView.queryTextChangeEvents(mSearchView)
                    .subscribeOn(AndroidSchedulers.mainThread())
                    .debounce(600, TimeUnit.MILLISECONDS, AndroidSchedulers.mainThread()) 
                    .filter(new Func1<SearchViewQueryTextEvent, Boolean>() {
                        @Override
                        public Boolean call(SearchViewQueryTextEvent searchViewQueryTextEvent) {
                            String query = searchViewQueryTextEvent.queryText().toString();
                            if (!TextUtils.isEmpty(query) && query.length() >= 11) {
                                if (!CommonUtil.isMobileNumber(query)) {
                                    PromptManager.getInstance().showToast("please input valid phone");
                                    return false;
                                }
                            }
                            boolean b =                             !TextUtils.isEmpty(searchViewQueryTextEvent.queryText().toString());
                            return b;
                        }
                    })
                    .switchMap(new Func1<SearchViewQueryTextEvent, Observable<BaseResponseWrapper<SearchUserResponse>>>() {
                        @Override
                        public Observable<BaseResponseWrapper<SearchUserResponse>> call(SearchViewQueryTextEvent searchViewQueryTextEvent) {
                             // Why run in the main thread here
                            //  2016/6/12 reset api request
                            String res = searchViewQueryTextEvent.queryText().toString();
                            return RetrofitManager.newInstance().getApi().searchUserByPhone(res);
                        }
                    })      
                     // switch io thread 
                    .subscribeOn(Schedulers.io())
                    .map(new Func1<BaseResponseWrapper<SearchUserResponse>, List<SearchUserResponse>>() {
                        @Override
                        public List<SearchUserResponse> call(BaseResponseWrapper<SearchUserResponse> fuzzyUserRes) {
                                // some code here            
                        }
                    })
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribe(new Subscriber<List<SearchUserResponse>>() {
                        @Override
                        public void onCompleted() {
                        }
                        @Override
                        public void onError(Throwable e) {
                            LogUtils.w("end thread:" + Thread.currentThread().getName());
                            LogUtils.w("e :" + e);
                            **//there throw exception android.os.NetworkOnMainThreadException**
                        }
                        @Override
                        public void onNext(List<SearchUserResponse> fuzzyUsers) {
                            updateUI(fuzzyUsers);
                        }
                    });

When I input to the searchview , onError method will throw android.os.NetworkOnMainThreadException. I have been in the After switchmap switch to the IO thread. I use rxjava version ： 'io.reactivex:rxjava:1.1.5'. what can I do?

Answer 1

You can't call subscribeOn twice in the same stream. Only the first will count.

Your code should look like this:

mSubscription = RxSearchView.queryTextChangeEvents(mSearchView)
                .debounce(600, TimeUnit.MILLISECONDS, AndroidSchedulers.mainThread())
                .filter(new Func1<SearchViewQueryTextEvent, Boolean>() {
                    @Override
                    public Boolean call(SearchViewQueryTextEvent searchViewQueryTextEvent) {
                        String query = searchViewQueryTextEvent.queryText().toString();
                        if (!TextUtils.isEmpty(query) && query.length() >= 11) {
                            if (!CommonUtil.isMobileNumber(query)) {
                                PromptManager.getInstance().showToast("please input valid phone");
                                return false;
                            }
                        }
                        boolean b =                             !TextUtils.isEmpty(searchViewQueryTextEvent.queryText().toString());
                        return b;
                    }
                })
                // switch io thread
                .observeOn(Schedulers.io())
                .switchMap(new Func1<SearchViewQueryTextEvent, Observable<BaseResponseWrapper<SearchUserResponse>>>() {
                    @Override
                    public Observable<BaseResponseWrapper<SearchUserResponse>> call(SearchViewQueryTextEvent searchViewQueryTextEvent) {
                        // Why run in the main thread here
                        //  2016/6/12 reset api request
                        String res = searchViewQueryTextEvent.queryText().toString();
                        return RetrofitManager.newInstance().getApi().searchUserByPhone(res);
                    }
                })
                .map(new Func1<BaseResponseWrapper<SearchUserResponse>, List<SearchUserResponse>>() {
                    @Override
                    public List<SearchUserResponse> call(BaseResponseWrapper<SearchUserResponse> fuzzyUserRes) {
                        // some code here
                    }
                })
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Subscriber<List<SearchUserResponse>>() {
                    @Override
                    public void onCompleted() {
                    }
                    @Override
                    public void onError(Throwable e) {
                        LogUtils.w("end thread:" + Thread.currentThread().getName());
                        LogUtils.w("e :" + e);
                        **//there throw exception android.os.NetworkOnMainThreadException**
                    }
                    @Override
                    public void onNext(List<SearchUserResponse> fuzzyUsers) {
                        updateUI(fuzzyUsers);
                    }
                });

As long as observeOn is a downstream operator, you should use them to switch over threads many times.

Hope that it helps.