前言: 最近想实现一个仿淘宝的搜索联想功能,进过查询发现需要用到retrofit2+rxjava2来实现基本功能。
其中,Rxjava需要使用一个叫PublishSubject的类,而这个类有一个叫debounce 的方法可以供我们实现:
当输入框发生变化时,不会立刻将事件发布出去,而是等待xxms,如果在这段事件内,输入框没有发生变化,那么才发送该事件;反之,则在收到新的关键词后,继续等待xxms。
举例代码如下:
PublishSubject<String> mPublishSubject;
mPublishSubject.debounce(200, TimeUnit.MILLISECONDS)
debounce方法的第一个参数是时间,第二个是时间的单位
源代码如下:
public final Observable<T> debounce(long timeout, TimeUnit unit)
{
return this.debounce(timeout, unit, Schedulers.computation());
}
public enum TimeUnit {
DAYS,
HOURS,
MICROSECONDS,
MILLISECONDS,
MINUTES,
NANOSECONDS,
SECONDS;
private TimeUnit() {
}
}
接着使用filter操作符。filter作用:对源Observable产生的结果按照指定条件进行过滤,只有满足条件的结果才会提交给订阅者。
PublishSubject.debounce(200, TimeUnit.MILLISECONDS)
.filter(new Predicate<String>() {
@Override
public boolean test(String s) throws Exception {
return s.length() > 0;
}
})
使用switchMap操作符,这样当发起了abc的请求之后,即使ab的结果返回了,也不会发送给下游,从而避免了出现前面介绍的搜索词和联想结果不匹配的问题。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() {
}
});
PublishSubject在订阅时并不立即触发订阅事件,允许我们在任意时刻手动调用onNext(),onError(),onCompleted来触发事件。
例如:
private void startSearch(String query) {
mPublishSubject.onNext(query);
}
最后: 希望能够对你有帮助,并且喜欢的可以点个赞,对我表示鼓励,我会感激不尽!