你的位置:首页 > 操作系统

[操作系统]RxJava 和 RxAndroid 四(RxBinding的使用)


对Rxjava不熟悉的同学可以先看我之前写的几篇文章

RxJava 和 RxAndroid 一 (基础)
RxJava 和 RxAndroid 二(操作符的使用)
RxJava 和 RxAndroid 三(生命周期控制和内存优化)


另外推荐几篇比较好的文章,有助于理解Rxjava
安卓客户端是如何使用 RxJava 的
通过 RxJava 实现一个 Event Bus – RxBus
玩透RxJava(一)基础知识
RxJava 教程第二部分:事件流基础之 过滤数据
Meizhi Android之RxJava & Retrofit最佳实践


前言:RxBinding 是 Jake Wharton 的一个开源库,它提供了一套在 Android 平台上的基于 RxJava的 Binding API。所谓 Binding,就是类似设置 OnClickListener 、设置 TextWatcher 这样的注册绑定对象的 API。

一:git地址

https://github.com/JakeWharton/RxBinding

二、androidStudio 使用

一般的包下面就用

compile 'com.jakewharton.rxbinding:rxbinding:0.4.0'

v4'support-v4' library bindings:

compile 'com.jakewharton.rxbinding:rxbinding-support-v4:0.4.0'

'appcompat-v7' library bindings:

compile 'com.jakewharton.rxbinding:rxbinding-appcompat-v7:0.4.0'

'design' library bindings:

compile 'com.jakewharton.rxbinding:rxbinding-design:0.4.0'

三、代码示例

  • Button 防抖处理

     button = (Button) findViewById( R.id.bt ) ;   RxView.clicks( button )       .throttleFirst( 2 , TimeUnit.SECONDS )  //两秒钟之内只取一个点击事件,防抖操作       .subscribe(new Action1<Void>() {         @Override         public void call(Void aVoid) {           Toast.makeText(MainActivity.this, "点击了", Toast.LENGTH_SHORT).show();         }       }) ;
  • 按钮的长按时间监听

     button = (Button) findViewById( R.id.bt ) ; //监听长按时间 RxView.longClicks( button)   .subscribe(new Action1<Void>() {     @Override     public void call(Void aVoid) {     Toast.makeText(MainActivity.this, "long click !!", Toast.LENGTH_SHORT).show();     }   }) ;
  • listView 的点击事件、长按事件处理

    listView = (ListView) findViewById( R.id.listview ); List<String> list = new ArrayList<>() ;   for ( int i = 0 ; i < 40 ; i++ ){     list.add( "sss" + i ) ;   } final ArrayAdapter<String> adapter = new ArrayAdapter<String>(this, android.R.layout.simple_expandable_list_item_1 );   adapter.addAll( list ); listView.setAdapter( adapter ); //item click event RxAdapterView.itemClicks( listView )   .subscribe(new Action1<Integer>() {     @Override     public void call(Integer integer) {     Toast.makeText(ListActivity.this, "item click " + integer , Toast.LENGTH_SHORT).show();       }     }) ; //item long click RxAdapterView.itemLongClicks( listView)   .subscribe(new Action1<Integer>() {     @Override     public void call(Integer integer) {       Toast.makeText(ListActivity.this, "item long click " + integer , Toast.LENGTH_SHORT).show();       }     }) ;
- 用户登录界面,勾选同意隐私协议,登录按钮就变高亮
button = (Button) findViewById( R.id.login_bt );checkBox = (CheckBox) findViewById( R.id.checkbox );RxCompoundButton.checkedChanges( checkBox )  .subscribe(new Action1<Boolean>() {    @Override    public void call(Boolean aBoolean) {      button.setEnabled( aBoolean );      button.setBackgroundResource( aBoolean ? R.color.button_yes : R.color.button_no );      }    }) ;```

效果图

  • 搜索的时候,关键词联想功能 。debounce()在一定的时间内没有操作就会发送事件。

     editText = (EditText) findViewById( R.id.editText ); listView = (ListView) findViewById( R.id.listview ); final ArrayAdapter<String> adapter = new ArrayAdapter<String>(this, android.R.layout.simple_expandable_list_item_1 ); listView.setAdapter( adapter ); RxTextView.textChanges( editText )       .debounce( 600 , TimeUnit.MILLISECONDS )       .map(new Func1<CharSequence, String>() {         @Override         public String call(CharSequence charSequence) {           //get the keyword           String key = charSequence.toString() ;           return key ;         }       })       .observeOn( Schedulers.io() )       .map(new Func1<String, List<String>>() {         @Override         public List<String> call(String keyWord ) {           //get list           List<String> dataList = new ArrayList<String>() ;           if ( ! TextUtils.isEmpty( keyWord )){             for ( String s : getData() ) {               if (s != null) {                 if (s.contains(keyWord)) {                   dataList.add(s);                 }               }             }           }           return dataList ;         }       })       .observeOn( AndroidSchedulers.mainThread() )       .subscribe(new Action1<List<String>>() {         @Override         public void call(List<String> strings) {           adapter.clear();           adapter.addAll( strings );           adapter.notifyDataSetChanged();         }       }) ;

    运行效果

总结

  • RxBinding就是把 发布--订阅 的模式用在了android控件的点击,文本变化上。通过 RxBinding 把点击监听转换成 Observable 之后,就有了对它进行扩展的可能。

  • RxBindingrxlifecycle 结合起来使用,可以控制控件监听的生命周期。关于rxlifecycle的使用,请参照RxJava 和 RxAndroid 三(生命周期控制和内存优化)

  • 这个系列的代码示例都在 github https://github.com/zyj1609wz/RxJava_RxAndroid

  • 最后我的个人微信公众号是:zhaoyanjun125 , 欢迎关注