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 {
//输入内容非空的时候才开始搜索 startSearch(s.toString());
}
}
}
);
mPublishSubject = PublishSubject.create();
mPublishSubject.debounce(200, TimeUnit.MILLISECONDS) //这里我们限制只有在输入字符200毫秒后没有字符没有改变时才去请求网络，节省了资源 .filter(new Predicate<String>() {
//对源Observable产生的结果按照指定条件进行过滤，只有满足条件的结果才会提交给订阅者 @Override public boolean test(String s) throws Exception {
//当搜索词为空时，不发起请求 return s.length() > 0;
}
}
) /** * flatmap:把Observable产生的结果转换成多个Observable，然后把这多个Observable “扁平化”成一个Observable，并依次提交产生的结果给订阅者 *concatMap:操作符flatMap操作符不同的是，concatMap操作符在处理产生的Observable时， 采用的是“连接(concat)”的方式，而不是“合并(merge)”的方式， 这就能保证产生结果的顺序性，也就是说提交给订阅者的结果是按照顺序提交的，不会存在交叉的情况 *switchMap:与flatMap操作符不同的是，switchMap操作符会保存最新的Observable产生的 结果而舍弃旧的结果 **/ .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) {
//显示搜索联想的结果 showSearchResult(s);
}
@Override public void onError(Throwable throwable) {
}
@Override public void onComplete() {
}
}
);
mCompositeDisposable = new CompositeDisposable();
mCompositeDisposable.add(mCompositeDisposable);
}
//开始搜索 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, "开始请求，关键词为：" + query);
try {
Thread.sleep(100);
//模拟网络请求，耗时100毫秒 }
catch (InterruptedException e) {
if (!observableEmitter.isDisposed()) {
observableEmitter.onError(e);
}
}
if (!(query.contains("科") || query.contains("耐") || query.contains("七"))) {
//没有联想结果，则关闭pop mPop.dismiss();
return;
}
Log.d("SearchActivity", "结束请求，关键词为：" + query);
observableEmitter.onNext(query);
observableEmitter.onComplete();
}
}
).subscribeOn(Schedulers.io());
}