将RxTextView文本更改事件与Retrofit调用相结合

Question

我是新手,RxJava只是尝试实现一些例子来更好地理解发生了什么,所以我想到的EditText是一个Observable并textChangeEvent使用RxBinding库发出:

        RxTextView.textChangeEvents(searchbar.getEditText())
            .debounce(400, TimeUnit.MILLISECONDS)
            .filter(new Func1<TextViewTextChangeEvent, Boolean>() {
                @Override
                public Boolean call(TextViewTextChangeEvent text) {
                    return (text.text().length() > 2);
                }
            })
            .subscribeOn(AndroidSchedulers.mainThread())
            .observeOn(Schedulers.io());

和Retrofitapi调用,其中呼叫的文本来自Observable上面.

所以我宣布了一个功能:

@Override
public Observable<SearchResponse> executeSearch(Observable<RxTextView> queryText) {
    return searchService.getSearch(queryText)
            .subscribeOn(Schedulers.newThread())
            .observeOn(AndroidSchedulers.mainThread());
}

现在我必须将这两者结合起来,所以当文本发生变化时,会有一个新的Retrofit呼叫,但我不知道如何"传递" queryText到服务.

我也尝试过:

Observable<TextViewTextChangeEvent>  
    searchBarText = RxTextView.textChangeEvents(searchbar.getEditText())
            .debounce(400, TimeUnit.MILLISECONDS)
            .filter(new Func1<TextViewTextChangeEvent, Boolean>() {
                @Override
                public Boolean call(TextViewTextChangeEvent text) {
                    Timber.i("Executes!!! text : %s", text.text().toString());
                    return (text.text().length() > 2);
                }
            })
            .subscribeOn(AndroidSchedulers.mainThread())
            .observeOn(Schedulers.io());

    Observable.combineLatest(executeSearchTypeOne(searchBarText), executeSearchTypeTwo(searchBarText),
                    new Func2<TypeOne, TypeTwo, Object>() {
                        @Override
                        public Object call(TypeOne one, TypeTwo two) {

                            return null;
                        }
                    })
            .subscribe(new Action1<Object>() {
                @Override
                public void call(Object o) {
                    Timber.i("WORKS!!!");
                }
            });

我希望Retrofit根据EditText更改同时运行两个调用,但它们根本不运行

Answer 1

我假设searchService.getSearch queryText参数的类型是String，并返回一个Observable of Data。

我会这样写：

RxTextView.textChangeEvents(searchbar.getEditText())
        .debounce(400, TimeUnit.MILLISECONDS)
        .map(new Func1<TextViewTextChangeEvent, String>() {
            @Override
            public String call(TextViewTextChangeEvent text) {
                return text.text().toString();
            }
        })
        .filter(new Func1<String, Boolean>() {
            @Override
            public Boolean call(String text) {
                return (text.length() > 2);
            }
        })
        .flatMap(new Func1<String, rx.Observable<Data>>() {
            @Override
            public rx.Observable<Data> call(String text) {
                return getSearch(text);
            }
        })
        .subscribeOn(Schedulers.io()) // Or Schedulers.newThread()
        .observeOn(AndroidSchedulers.mainThread());

这是一个Observable of Data，从TextViewTextChangeEvent的Observable映射到String到与getSearch（一个Observable Data）链接。

对于 Kotlin（Killer 最初提议）：

RxTextView.textChangeEvents(searchbar.getEditText())
                .debounce(400, TimeUnit.MILLISECONDS) // Better store the value in a constant like Constant.DEBOUNCE_SEARCH_REQUEST_TIMEOUT
                .map { it.text().toString() }
                .filter { it.length > 2 }
                .flatMap { getSearch(it) } // Or .flatMap(this::getSearch)
                .subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe { ... }

注意：一旦运行 onError() 方法，RxTextView.textChanges 将不会发出文本更改。参考： https: //github.com/JakeWharton/RxBinding/issues/272