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 之後，就有了對它進行擴充的可能。

• RxBinding

  和

  rxlifecycle

  結合起來使用，可以控制控件監聽的生命周期。關于

  rxlifecycle

  的使用，請參照RxJava 和 RxAndroid 三（生命周期控制和記憶體優化）
• 這個系列的代碼示例都在 github https://github.com/zyj1609wz/RxJava_RxAndroid
• 最後我的個人微信公衆号是：

  zhaoyanjun125

  , 歡迎關注
• RxJava 和 RxAndroid 五（線程排程）