需要 RXJava 异步帮助。输入被调用阻塞

Question

我有以下代码，可以很好地在列表视图中显示结果。问题是键入时调用会阻塞键盘，但是当我尝试在 io 线程上订阅时它不起作用。我的问题是：调用我的休息界面的正确位置在哪里？

o1 = RxTextView.textChangeEvents(etSearch).throttleLast(500, TimeUnit.MILLISECONDS)
            .map(new Func1<RxTextViewTextChangeEvent, String>() {
                     @Override
                     public String call(RxTextViewTextChangeEvent rxTextViewTextChangeEvent) {
                         return etSearch.getText().toString();
                     }
                 }
            );
    o1.observeOn(RxAndroidSchedulers.mainThread()).filter(new Func1<String, Boolean>() {
        @Override
        public Boolean call(String s) {
            return s.length() > 2;
        }
    }).subscribe(new Action1<String>() {
        @Override
        public void call(String s) {

                List<CrewMember> crewMemberList = rest.getCrewMemberList(s);
                ListView crewFinderResultsListView = (ListView) findViewById(R.id.list);
                crewMemberAdapter = new CrewFinderResultRowAdapter(mContext, getLayoutInflater());
                crewMemberAdapter.setCrewMemberList(crewMemberList);
                crewFinderResultsListView.setAdapter(crewMemberAdapter);

        }
    });

Answer 1

我的猜测是rest.getCrewMemberList(s) 是网络调用或其他阻止主线程的阻塞调用。如果是第一个，您可能会在主线程异常上得到一个网络，因为您没有使用带有错误回调的subscribe 重载，所以该异常被吞没了。您必须将调用移至 io() 调度程序：

RxTextView.textChangeEvents(etSearch)
    .throttleLast(500, SECONDS)
    .filter(s -> s.length() > 2)
    .switchMap(s -> 
        Observable.fromCallable(() -> rest.getCrewMemberList(s))
        .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe(crewMembersList -> {
        ListView crewFinderResultsListView = (ListView) findViewById(R.id.list);
            crewMemberAdapter = new CrewFinderResultRowAdapter(
                mContext, getLayoutInflater());
            crewMemberAdapter.setCrewMemberList(crewMemberList);
            crewFinderResultsListView.setAdapter(crewMemberAdapter);
    },
    e -> Log.d(...));