1

我正在尝试使用RxJava for Android。我正在尝试一个简单的示例，我试图在后台线程上卸载更长的操作，然后期望回到主线程并执行 ui 操作。

我从一个EditText onTextChangeListener（通过漂亮的 ButterKnife 注入）获取搜索文本，然后将其发送到一个长时间运行的操作_searchForContacts(searchText)，该操作返回一个联系人对象列表。然后我通过在我的适配器上设置信息并通知数据集更改来继续更新我的视图。

但是，我在尝试进行任何 ui 更新时遇到了异常，因为我从来没有在主线程上。

这是我的代码：

public class MyTestFragment
    extends Fragment
    implements Observer<List<Contact>> {

    // ...

    private Subscription _searchGuestsSubscription = Subscriptions.empty();

    // ...

    @Override
    public void onDestroyView() {
        super.onDestroyView();
        _searchGuestsSubscription.unsubscribe();
    }

    @Override
    public void onActivityCreated(Bundle savedInstanceState) {
        super.onActivityCreated(savedInstanceState);
        _adapter = new ContactImportAdapter();
        _adapter.setContacts(_searchForContacts(ALL_CONTACTS));
        _listView.setAdapter(_adapter);
    }

    @Override
    public void onNext(List<Contact> contactSearchResults) {
        Timber.d("I'm on the main thread -> " + String.valueOf(Looper.myLooper() == Looper.getMainLooper()));
        _adapter.setContacts(contactSearchResults);
    }

    @Override
    public void onCompleted() {
        _updateView();
    }

    @Override
    public void onError(Throwable e) {
        Timber.e(e, "Oops something went wrong.");
    }

    // ButterKnife ~ onTextChangeListener
    @OnTextChanged(R.id.search_edit_text)
    void onSearchContact(CharSequence searchChars) {
        _searchGuestsSubscription = AndroidObservable.bindFragment(this,
                                                                   _searchGuestsObservable(searchChars.toString()))
                                                     // The below line doesn't seem to have any effect?
                                                     .observeOn(AndroidSchedulers.mainThread())
                                                     .subscribeOn(Schedulers.io())
                                                     .subscribe(this);
    }

    private Observable<List<Contact>> _searchGuestsObservable(final String searchText) {
        return Observable.create(new Observable.OnSubscribe<List<Contact>>() {


            @Override
            public void call(Subscriber<? super List<Contact>> searchResultObserver) {
                // do the search
                List<Contact> contactSearchResults = _searchForContacts(searchText);
                onNext(contactSearchResults);
                onCompleted();
            }
        });
    }

    private void _updateView() {
        _adapter.notifyDataSetChanged();
    }
}

它说onNext总是在后台线程上调用。我得到了通常的IllegalStateException: The current thread must have a looper!例外。日志语句还表明我不在onNext.

是什么赋予了？

4

1 回答 1

1

您的问题似乎来自您直接在 Fragment 中调用 onNext 而不是在订阅者上调用 onNext 的事实。

像这样更改您的代码。

private Observable<List<Contact>> _searchGuestsObservable(final String searchText) {
    return Observable.create(new Observable.OnSubscribe<List<Contact>>() {
        @Override
        public void call(Subscriber<? super List<Contact>> searchResultObserver) {
            // do the search
            List<Contact> contactSearchResults = _searchForContacts(searchText);
            searchResultObserver.onNext(contactSearchResults);
            searchResultObserver.onCompleted();
        }
    });
}

当你Observable.OnSubscribe<List<Contact>>()被执行时，你实际上是在后台线程上，因为subscribeOn(Schedulers.io())你自己调用你的 Fragment 的 onNext，这就是你得到那个异常的原因。

于 2014-07-23T12:16:50.250 回答