zoukankan      html  css  js  c++  java
  • Rxjava2的操作符Filter、Debounce 、DistinctUntilChanged 、SwitchMap 的使用

    public class RxSearchObservable {
        public static Observable<String> fromView(SearchView searchView) {
          //Subject的理解看这里 https://www.cnblogs.com/yongfengnice/p/10229473.html
    final PublishSubject<String> subject = PublishSubject.create(); searchView.setOnQueryTextListener(new SearchView.OnQueryTextListener() { @Override public boolean onQueryTextSubmit(String s) { subject.onComplete(); return true; } @Override public boolean onQueryTextChange(String text) { subject.onNext(text); return true; } }); return subject; } } RxSearchObservable.fromView(searchView) .debounce(300, TimeUnit.MILLISECONDS)  //时间跨度300毫秒以上才触发 .filter(new Predicate<String>() {    //过滤,下面的test是过滤条件 @Override public boolean test(String text) throws Exception { if (text.isEmpty()) { return false; } else { return true; } } }) .distinctUntilChanged()        //去重,比如一开始是abc,用户在300毫秒内删除c再输入c,300毫秒后也不会重新再次触发。 .switchMap(new Function<String, ObservableSource<String>>() {  //只取最新的结果,比如请求ab很久了还没回来又请求了abc,只取最后的abc的结果。 @Override public ObservableSource<String> apply(String query) throws Exception { return dataFromNetwork(query); } }) .subscribeOn(Schedulers.io())  //io耗时操作子线程 .observeOn(AndroidSchedulers.mainThread())  //ui更新线程 .subscribe(new Consumer<String>() { @Override public void accept(String result) throws Exception { textViewResult.setText(result); } });
  • 相关阅读:
    03-高级选择器,属性选择器,伪类选择器
    02-css的选择器
    01- css引入方式
    HTML(三)
    HTML(二)
    Sublime text3 插件ColorPicker(调色板)不能使用快捷键的解决方法
    Sublime Text 3 快捷键汇总
    Sublime Text 3下载及常用插件安装
    box-shadow参数以及使用
    jquery.nav.js定位导航滚动插件
  • 原文地址:https://www.cnblogs.com/yongfengnice/p/10229356.html
Copyright © 2011-2022 走看看