Как остановить множественные переназначения при использовании с помощью Rx-Java, используемого в функции поиска для Android?

Question

У меня есть функция поиска в приложении для Android. SearchView имеет обратный вызов onSearchTextChanged(String oldQuery, String newQuery). Эта функция обратного вызова вызывает каждый раз, когда пользователь вводит любой текст в поле поиска. У меня есть вызов REST в этом обратном вызове, который запускается каждый раз, когда набирается каждое слово. Это приводит к нескольким вызовам REST. Я хочу этого избежать. Я просто хочу, чтобы только один экземпляр активен в то время, которое является последним, и все остальные вызовы должны быть немедленно отменены всякий раз, когда набирается новое письмо. Ниже приведены данные кода.

@Override 
    public void onSearchTextChanged(String oldQuery, String newQuery) { 

     floatingSearchView.showProgress(); 
     moviesAPI.searchQuery(newQuery) 
       .subscribeOn(Schedulers.newThread()) 
       .observeOn(AndroidSchedulers.mainThread()) 
       .subscribe(new Subscriber<Search>() { 
           @Override 
           public void onCompleted() { 
            Log.d(TAG, "onCompleted() called"); 
           } 

           @Override 
           public void onError(Throwable e) { 
            Log.d(TAG, "onError() called with: e = [" + e + "]"); 
           } 

           @Override 
           public void onNext(Search search) { 
            floatingSearchView.hideProgress(); 
            floatingSearchView.swapSuggestions(search.getSearchResults()); 
            Log.d(TAG, "onNext() called with: search = [" + search + "]"); 
           } 
          } 

       ); 

    } 

Answer 1

Возможно, вы захотите использовать debounce для задержки поисковых запросов при вводе (и только после того, как пользователь перестанет печатать на протяжении продолжительности x).

Кроме того, для отмены старых запросов при поступлении нового запроса вы можете преобразовать события изменения текста в поток событий (вручную или с помощью библиотеки, такой как RxBindings), а затем переключить каждое новое текстовое событие на запрос. Оператор switchMap отменит предыдущий запрос, который все еще продолжается, когда новый запрос поступает с помощью нового текстового потока поиска.

вы нашли различные примеры реализации предложений поиска для андроида с rxjava, как этот по Кошику Гопал: instantauto-searching-text-listeners-using-subjects--debounce

пример кода, в данном примере используется RxBinding библиотеки легко получать textChanages события в потоке наблюдаемого.

RxTextView.textChangeEvents(tv) 
       .debounce(300, TimeUnit.MILLISECONDS) 
       .switchMap(new Func1<TextViewTextChangeEvent, Observable<SearchResult>>() { 
        @Override 
        public Observable<SearchResult> call(
          TextViewTextChangeEvent textViewTextChangeEvent) { 
         return moviesAPI.searchQuery(textViewTextChangeEvent.text().toString()) 
           .subscribeOn(Schedulers.io()); 
        } 
       }) 
       .subscribe(new Subscriber<SearchResult>() { 
        @Override 
        public void onCompleted() { 
         Log.d(TAG, "onCompleted() called"); 
        } 

        @Override 
        public void onError(Throwable e) { 
         floatingSearchView.hideProgress(); 
         Log.d(TAG, "onError() called with: e = [" + e + "]"); 
        } 

        @Override 
        public void onNext(SearchResult search) { 
         floatingSearchView.hideProgress(); 
         floatingSearchView.swapSuggestions(search.getSearchResults()); 
         Log.d(TAG, "onNext() called with: search = [" + search + "]"); 
        } 
       });