带有 Retrofit 2、RxJava 和 RxBinding 的 AutoCompleteTextView

Question

我是 Rx 世界的新手，我尝试用 RxJava、RxBinding 和 Retrofit 2 来实现我的 AutoCompleteTextView。

这是我想出来的，但很麻烦：（也许我做的方式不对。）

我有一个 AutoCompleteTextView，我在这里创建了我的订阅和可观察对象：

subcription = RxTextView.textChangeEvents(clearableEditText)
                .skip(1)
                .debounce(400, TimeUnit.MILLISECONDS)
                .map(new Func1<TextViewTextChangeEvent, String>() {
                    @Override
                    public String call(TextViewTextChangeEvent textViewTextChangeEvent) {
                        return textViewTextChangeEvent.text().toString();
                    }
                })
                .filter(new Func1<String, Boolean>() {
                    @Override
                    public Boolean call(String s) {
                        return s.length() > 2;
                    }
                })
                .flatMap(new Func1<String, Observable<List<String>>>() {
                    @Override
                    public Observable<List<String>> call(String text) {
                        return searchService.getAutoCompleteTermsObservable(text)
                                .subscribeOn(Schedulers.io())
                                .observeOn(AndroidSchedulers.mainThread());
                    }
                })
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(new Subscriber<List<String>>() {
                    @Override
                    public void onCompleted() {
                        Log.d("rx", "oncomplete");
                    }

                    @Override
                    public void onError(Throwable e) {
                        Log.e("rx", e.toString());
                    }

                    @Override
                    public void onNext(List<String> strings) {
                        Log.d("rx", strings.size()+"");
                        autoAdapter = new ArrayAdapter<>(MainActivity.this,
                                android.R.layout.simple_dropdown_item_1line, strings);
                        clearableEditText.setAdapter(autoAdapter);
                        clearableEditText.showDropDown();
                    }
                });

我的问题是当我使用 setText() 方法设置我的 EditText 时，它会触发下拉菜单。例如，当我从 AutoCompleteTextView 的下拉列表中设置单词以及使用语音输入设置它时，它就会执行此操作。当我手动设置时，有没有办法避免触发 onTextChanged？或者我该如何解决？

Answer 1

您确实可以使用 unsubscribe()，但根据您设置值的方式，您也可以使用 skipWhile。这是一个例子：

public void handleTextChanges() {
    final String textFromSource = "an";

    Observable.fromArray("a", "an", "ancestor")
            .skipWhile(new Predicate<String>() {
                @Override
                public boolean test(String value) throws Exception {
                    return textFromSource.contains(value);
                }
            })
            .subscribe(new Consumer<String>() {
                @Override
                public void accept(String value) throws Exception {
                    Log.d("Rx", value);
                }
            });
}

这只会消耗 ancestor（示例是 RxJava2，但存在相同的方法）。任何后续值，即使它们匹配 an，也将被消耗。如果你总是想像这样进行检查，你可以使用 filter

带有 Retrofit 2、RxJava 和 RxBinding 的 AutoCompleteTextView

AutoCompleteTextView with Retrofit 2, RxJava and RxBinding

android

retrofit2

rx-android

rx-binding

rx-java2