Combine RxTextView text change events using the Retrofit feature

I am new to RxJavaand just trying to implement a few examples to better understand what is happening, so I thought it EditTextwas Observable and emits textChangeEventusing the libraryRxBinding

        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());

and a Retrofitapi, where is the text to call from Observableabove.

So, I declared a function:

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

And now I need to combine these two, so when the text changes a new call there Retrofit, but I don’t know how I can “pass” the queryTextservice.

I also tried:

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!!!");
                }
            });

where I want to start two calls Retrofitat the same time based on the changes EditText, but they do not start at all

+4
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());

TextViewTextChangeEvent, String, getSearch, .

( 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 { ... }

. RxTextView.textChanges onError(). : https://github.com/JakeWharton/RxBinding/issues/272

+2

Source: https://habr.com/ru/post/1669381/


All Articles