的Android，RXJava，使用去抖

Question

搜索我使用debounce()處理用戶的搜索和（最後一個字符後，搜索1秒）上鍵入它的暫停處理：

RxSearchView.queryTextChanges(searchView) 
      .debounce(1, TimeUnit.SECONDS) 
      .subscribe(new Action1<CharSequence>() { 
       @Override 
       public void call(CharSequence charSequence) { 
        presenter.loadUsers(charSequence.toString()); 
       } 
      }); 

因此，如果用戶刪除所有字符，它等待1秒鐘，然後加載列表，我如何處理它並立即加載列表？

Answer 1

在你的情況下，需要只是debounce運營商使用不同的參數：

public final <U> Observable<T> debounce(Func1<? super T, ? extends Observable<U>> debounceSelector)

使用它可以過濾哪些事件可以延遲或不延遲：

RxSearchView.queryTextChanges(searchView) 
    .debounce(new Func1<CharSequence, Observable<CharSequence>>() { 
     @Override 
     public Observable<CharSequence> call(CharSequence charSequence) { 
      if (charSequence.length() == 0) { 
       return Observable.empty(); 
      } else { 
       return Observable.<CharSequence>empty().delay(1, TimeUnit.SECONDS); 
      } 
     } 
    }) 
    .subscribe(new Action1<CharSequence>() { 
     @Override 
     public void call(CharSequence charSequence) { 
      Log.d(MainActivity.class.getSimpleName(), new Date().toGMTString() + " " + charSequence.length() + " :" + charSequence); 
     } 
    }); 

Answer 2

在最簡單的形式只是merge去抖觀察到有手動觸發像這樣：

RxSearchView.queryTextChanges(searchView) 
     .debounce(1, TimeUnit.SECONDS) 
     .mergeWith(Observable.just("")) // manually tigger onNext with empty search 
     .subscribe(new Action1<CharSequence>() { 
      @Override 
      public void call(CharSequence charSequence) { 
       presenter.loadUsers(charSequence.toString()); 
      } 
     });