RxJavaオペレータDebounceが機能しない

Question

私はAndroidアプリケーションでプレースオートコンプリートを実装したいと思いますが、これはRetrofitとRxJavaを使用しています。私はユーザーが何かを入力した後に2秒ごとに応答したい。私はこれに対してdebounce演算子を使用しようとしていますが、動作しません。それはすぐに結果を私に与えています。 @BenPコメントで言うように

mAutocompleteSearchApi.get(input, "(cities)", API_KEY) 
      .debounce(2, TimeUnit.SECONDS) 
      .subscribeOn(Schedulers.io()) 
      .observeOn(AndroidSchedulers.mainThread()) 
      .flatMap(prediction -> Observable.fromIterable(prediction.getPredictions())) 
      .subscribe(prediction -> { 
       Log.e(TAG, "rxAutocomplete : " + prediction.getStructuredFormatting().getMainText()); 
      }); 

Answer 1

は、あなたがPlace Autocompleteサービスへdebounceを適用するように見えます。この呼び出しは、完了する前に単一の結果（またはエラー）を出すObservableを返します。その時点で、debounceオペレータはその唯一のアイテムを放出します。

// Subject holding the most recent user input 
BehaviorSubject<String> userInputSubject = BehaviorSubject.create(); 

// Handler that is notified when the user changes input 
public void onTextChanged(String text) { 
    userInputSubject.onNext(text); 
} 

// Subscription to monitor changes to user input, calling API at most every 
// two seconds. (Remember to unsubscribe this subscription!) 
userInputSubject 
    .debounce(2, TimeUnit.SECONDS) 
    .flatMap(input -> mAutocompleteSearchApi.get(input, "(cities)", API_KEY)) 
    .flatMap(prediction -> Observable.fromIterable(prediction.getPredictions())) 
    .subscribe(prediction -> { 
     Log.e(TAG, "rxAutocomplete : " + prediction.getStructuredFormatting().getMainText()); 
    });