RxJava RxBinding基础

RxBinding是什么

把 Android 中各种 UI 控件的事件转换为 RxJava 中的数据流。这样就可以把 UI 控件的事件当做 RxJava 中的数据流来使用了。 比如 View 的 onClick 事件,使用 RxView.clicks(view) 即可获取到一个 Observable 对象,每当用户点击这个 View 的时候,该 Observable 对象就发射一个事件(onNext 被调用), Observable 的 Observer 订阅者就可以通过 onNext 回调知道用户点击了 View。

开源项目

RxBinding 地址:https://github.com/JakeWharton/RxBinding

添加依赖

1
2
3
4
5
6
/ RxBinding
compile 'com.jakewharton.rxbinding:rxbinding:0.3.0'
compile 'com.jakewharton.rxbinding:rxbinding-support-v4:0.3.0'
compile 'com.jakewharton.rxbinding:rxbinding-appcompat-v7:0.3.0'
compile 'com.jakewharton.rxbinding:rxbinding-design:0.3.0'
compile 'com.jakewharton.rxbinding:rxbinding-recyclerview-v7:0.3.0'

简单使用

button点击事件

1
2
3
4
5
6
7
8
Button b = (Button)findViewById(R.id.button);
Subscription buttonSub =
RxView.clicks(b).subscribe(new Action1<Void>() {
@Override
public void call(Void aVoid) {
// do some work here
}
});

EditText添加文本改变事件

1
2
3
4
5
6
7
8
9
final EditText name = (EditText) v.findViewById(R.id.name);
Subscription editTextSub =
RxTextView.textChanges(name)
.subscribe(new Action1<String>() {
@Override
public void call(String value) {
// do some work with the updated text
}
});

看到这里你可能会说,这个没什么太大的变化呀,也没有什么太优势的地方。大佬别着急。

RxBinding最好的运用场景是在定时操作,循环操作。还有对重复点击事件的处理上

设置Button防止抖动

1
2
3
4
5
6
7
RxView.clicks(button).throttleFirst(2, TimeUnit.SECONDS).subscribe(new Action1<Void>() {
@Override
public void call(Void aVoid) {
//两秒钟之内只取一个点击事件,防抖操作
// do some work with the updated text
}
});

考虑在搜索框中输入相应的内容,当内容的长度至少三个字符长度的时候开始触发响应事件(设置100ms延迟),使用RxJava实现(debounce()在一定的时间内没有操作就会发送事件)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
RxTextView.textChanges(searchTextView)
.filter(new Func1<String, Boolean> (){
@Override
public Boolean call(String s) {
return s.length() > 2;
}
})
.debounce(100, TimeUnit.MILLISECONDS)
.switchMap(new Func1<String, Observable<List<Result>>>() {
makeApiCall(s);
})
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(/* attach observer */);

CheckBox相关的操作

在用户登录界面时,如果用户未勾选同意用户协议,不允许登录

1
2
3
4
5
6
7
8
RxCompoundButton.checkedChanges(checkBox2)
.subscribe(new Action1<Boolean>() {
@Override
public void call(Boolean aBoolean) {
btn_login.setClickable(aBoolean);
btn_login.setBackgroundResource(aBoolean ? R.color.can_login : R.color.not_login);
}
});

监听RecyclerView的滚动事件以及数据更改事件

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
RxRecyclerView.scrollStateChanges(mRxBindingRecycler)
.subscribe(new Action1<Integer>() {
@Override
public void call(Integer integer) {
Log.d("TAG", "change");
}
});
RxRecyclerViewAdapter.dataChanges(mAdapter)
.subscribe(new Action1<MyAdapter>() {
@Override
public void call(MyAdapter myAdapter) {
Log.e("TAG", "DATA CHANGED");
}
});
mAdapter.notifyDataSetChanged();

因为RxRecyclerView和RecyclerView一样并没有提供直接的item点击事件,所以参考以前RecyclerView写了一个点击事件这里用到了RxBus处理数据的传递,我们并没有在RecyclerView内部直接去处理事件

1
2
3
4
5
6
7
8
9
10
11
12
13
14
@Override
public MyAdapter.ViewHolder onCreateViewHolder(ViewGroup parent, int viewType) {
final View view = LayoutInflater.from(mContext).inflate(R.layout.binding_item, null);
final ViewHolder viewHolder = new ViewHolder(view);
RxView.clicks(view)
.subscribe(new Action1<Void>() {
@Override
public void call(Void aVoid) {
RxBus.getInstance().send(new UserBean("",viewHolder.getAdapterPosition()+""));
Log.i("TGA",viewHolder.getAdapterPosition()+"");
}
});
return viewHolder;
}

在我们处理数据的地方获取该事件

1
2
3
4
5
6
7
8
9
RxBus.getInstance()
.toObserverable(UserBean.class)
.subscribe(new Action1<UserBean>() {
@Override
public void call(UserBean userBean) {
// TODO: 2017/3/13
}
});

当然上面的只是一些简单的案例,具体的内容请观看大神的RxBinding

dreamY wechat
可以的话加我好友一起学习~