private void initEdt() {
    editText = (EditText) findViewById(R.id.edt);
    editText.addTextChangedListener(new TextWatcher() {
      @Override
      public void beforeTextChanged(CharSequence s, int start, int count, int after) {

      }

      @Override
      public void onTextChanged(CharSequence s, int start, int before, int count) {

      }

      @Override
      public void afterTextChanged(Editable s) {
        if (s.toString().trim().isEmpty()) {
          mPop.dismiss();
        } else {
          //輸入內(nèi)容非空的時(shí)候才開(kāi)始搜索
          startSearch(s.toString());
        }
      }
    });

    mPublishSubject = PublishSubject.create();
    mPublishSubject.debounce(200, TimeUnit.MILLISECONDS) //這里我們限制只有在輸入字符200毫秒后沒(méi)有字符沒(méi)有改變時(shí)才去請(qǐng)求網(wǎng)絡(luò)，節(jié)省了資源
        .filter(new Predicate<String>() { //對(duì)源Observable產(chǎn)生的結(jié)果按照指定條件進(jìn)行過(guò)濾，只有滿足條件的結(jié)果才會(huì)提交給訂閱者

          @Override
          public boolean test(String s) throws Exception {
            //當(dāng)搜索詞為空時(shí)，不發(fā)起請(qǐng)求
            return s.length() > 0;
          }

        })
        /**
         * flatmap:把Observable產(chǎn)生的結(jié)果轉(zhuǎn)換成多個(gè)Observable，然后把這多個(gè)Observable
         “扁平化”成一個(gè)Observable，并依次提交產(chǎn)生的結(jié)果給訂閱者

         *concatMap:操作符flatMap操作符不同的是，concatMap操作符在處理產(chǎn)生的Observable時(shí)，
         采用的是“連接(concat)”的方式，而不是“合并(merge)”的方式，
         這就能保證產(chǎn)生結(jié)果的順序性，也就是說(shuō)提交給訂閱者的結(jié)果是按照順序提交的，不會(huì)存在交叉的情況

         *switchMap:與flatMap操作符不同的是，switchMap操作符會(huì)保存最新的Observable產(chǎn)生的
         結(jié)果而舍棄舊的結(jié)果
         **/
        .switchMap(new Function<String, ObservableSource<String>>() {

          @Override
          public ObservableSource<String> apply(String query) throws Exception {
            return getSearchObservable(query);
          }

        })
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(new DisposableObserver<String>() {

          @Override
          public void onNext(String s) {
            //顯示搜索聯(lián)想的結(jié)果
            showSearchResult(s);
          }

          @Override
          public void onError(Throwable throwable) {

          }

          @Override
          public void onComplete() {

          }
        });
    mCompositeDisposable = new CompositeDisposable();
    mCompositeDisposable.add(mCompositeDisposable);
  }

  //開(kāi)始搜索
  private void startSearch(String query) {
    mPublishSubject.onNext(query);
  }

  private Observable<String> getSearchObservable(final String query) {
    return Observable.create(new ObservableOnSubscribe<String>() {

      @Override
      public void subscribe(ObservableEmitter<String> observableEmitter) throws Exception {
        Log.d(TAG, "開(kāi)始請(qǐng)求，關(guān)鍵詞為：" + query);
        try {
          Thread.sleep(100); //模擬網(wǎng)絡(luò)請(qǐng)求，耗時(shí)100毫秒
        } catch (InterruptedException e) {
          if (!observableEmitter.isDisposed()) {
            observableEmitter.onError(e);
          }
        }
        if (!(query.contains("科") || query.contains("耐") || query.contains("七"))) {
          //沒(méi)有聯(lián)想結(jié)果，則關(guān)閉pop
          mPop.dismiss();
          return;
        }
        Log.d("SearchActivity", "結(jié)束請(qǐng)求，關(guān)鍵詞為：" + query);
        observableEmitter.onNext(query);
        observableEmitter.onComplete();
      }
    }).subscribeOn(Schedulers.io());
  }