目录
技术答疑，成长进阶，可以加入我的知识星球：音视频领域专业问答的小圈子
之前有写过一篇文章：用 RxJava 封装回调方法 CallBack。
RxJava 封装回调方法的大体思路就是：使用 Observable 的 create 方法来返回一个 Observable，在 create 方法内给事物设置回调接口，用 Observable 的 onNext 方法来接受回调接口所产生的内容。
这样一来，通过 onNext 方法就把事物的回调方法转换到 Rxjava 对应的事件流里面了，再可以通过其他操作符，如 Map、FlatMap 等对事件流进行相应的转换。
下来展示具体代码的操作，用的是 RxJava 2.x 的版本：
1 private Observable<Integer> handleRxJavaDialog() {
2 return Observable.create(emitter -> {
3 final AlertDialog dialog = new AlertDialog.Builder(mContext)
4 .setMessage("RxJava封装Dialog事件流")
5 .setNegativeButton("取消", (dialog12, which) -> emitter.onNext(which))
6 .setPositiveButton("确认", (dialog1, which) -> emitter.onComplete())
7 .create();
8 dialog.show();
9 // 当被取消订阅，unsubscribed 时调用的方法
10 emitter.setCancellable(() -> {
11 if (dialog.isShowing()) {
12 dialog.dismiss();
13 }
14 });
15 });
16 }如此封装之后，直接通过 RxJava 的 onNext 方法将事件封装到 RxJava 事件流里面去。
弄到这，想起了一个开源的 RxJava 系列框架：RxBinding，和本文的封装有相同之处。
RxBinding 实现简要分析
RxBinding 是用来处理控件异步调用的一个框架，它也已经更新到了 RxJava 2.x 的版本。
在它的源码里对许多控件都进行了封装，可以看到如：RxView、RxTextView、RxSeekBar、RxProgressBar、RxPopupMenu等等。
它们的使用也是大同小异，比如要对一个 View 封装其点击事件，就可以这样写：
1 RxView.clicks(mBtn)
2 .subscribe(new Consumer<Object>() {
3 @Override
4 public void accept(@NonNull Object o) throws Exception {
5 Timber.d("RxView");
6 }
7 });在代码的前半部分RxView.clicks(mBtn)返回的正好是一个 Observable 对象，然后就可以像平时使用 RxJava 一样添加各种操作符，最后通过 subscribe 进行订阅了。
在 RxView.clicks 的源码中，最后返回的是一个 ViewClickObservable，从名字可见，这个 Observable 专门是用来处理点击事件的，在 RxBinding 中还有很多专门处理其他事件的 Observable，例如：ViewDragObservable、ViewLongClickObservable、ViewScrollChangeEventObservable等等，他们的实现方法也都大同小异了。
1 @CheckResult @NonNull
2 public static Observable<Object> clicks(@NonNull View view) {
3 checkNotNull(view, "view == null");
4 return new ViewClickObservable(view);
5 }在专门处理各种事件的 Observable 类中，都会有一个实现 Disposable接口和具体事件所对应的接口的 Listener 类，而这个 Listener 类的作用，就是给我们所需要的 View 设置对应事件回调接口的，并且在回调接口中调用 Observable 的 onNext 方法来将事件转换到 RxJava 的事件流中。
1 ViewClickObservable(View view) {
2 this.view = view;
3 }
4
5 @Override protected void subscribeActual(Observer<? super Object> observer) {
6 if (!checkMainThread(observer)) {
7 return;
8 }
9 Listener listener = new Listener(view, observer);
10 // onSubscribe 设置了 Disposable 接口，当取消订阅时该执行的操作。
11 observer.onSubscribe(listener);
12 view.setOnClickListener(listener);
13 }
14// ViewClickObservable 的 Listener 类实现了 OnClickListener 接口
15 static final class Listener extends MainThreadDisposable implements OnClickListener {
16 private final View view;
17 private final Observer<? super Object> observer;
18
19 Listener(View view, Observer<? super Object> observer) {
20 this.view = view;
21 this.observer = observer;
22 }
23 // 在 onClick 方法内，调用 onNext 方法，将 onClick 的事件转移到了 RxJava 的事件流里面去了
24 @Override public void onClick(View v) {
25 if (!isDisposed()) {
26 observer.onNext(Notification.INSTANCE);
27 }
28 }
29 // 当被取消订阅时，就设置接口为 null.
30 @Override protected void onDispose() {
31 view.setOnClickListener(null);
32 }
33 }而在开始订阅时，就调用subscribeActual方法来给 View 设置回调接口以便转换事件流。并且还设置了Disposable以便响应当结束订阅时的操作。
这一逻辑和本文上半部分将的有相同之处，核心都是用 onNext 方法转换事件流。
而 RxBinding 则封装的更多了，没有在 create 方法里面进行操作， 而是针对 View 控件不同的事件来生成对应的 Observable 对象，对象里面持有 View 控件的实例，并且也完成了给 View 控件设置回调接口以及取消订阅时的方法。
但毫无疑问，针对 View 控件的事件来生成 Observable 会使得代码的兼容性更强了吧，毕竟大多数控件都有公共事件，而只需要针对这个功能事件写一遍代码就行了，不需要针对每个控件来实现一套代码了。
总结经验，写代码时还是要多想想，谋定而后动！！！
参考
1、http://adelnizamutdinov.github.io/blog/2014/11/23/advanced-rxjava-on-android-popupmenus-and-dialogs/
欢迎关注微信公众号：音视频开发进阶
