作为一个android开发者你也许现在正使用RxJava进行开发，即使你不曾使用过它至少你应该听说过它，当前有许多的库都使用了这种响应式方法，例如：RxPreferences、RxLocation、RxPermissions、RxWear。本篇文章将以RxBinding作为例子，好了让我们回到正题。
在我们近期开发的每一个项目中我们都使用了RxJava，因为它加快了应用的开发速度帮助我们避免了callback hell问题。我们将这种响应式方法应用到我们自定义的MVP框架中。在我们最近的开发项目中我们将这种响应式方法融合到了MVVM模式中。关于RxJava的使用场景许多开发者比较熟知的是RxJava与Retrofit的结合运用。其实RxJava能够运用到许多场景，比如我们在处理数据或事件流的时候，我们可以将它与Android Data Binding结合起来进行使用。接下来我将使用一个具体的例子进行说明:
1 | <Button
2 | android:layout_width="wrap_content"
3 | android:layout_height="wrap_content"
4 | android:enabled="@{StringUtils.isNotNullOrEmpty(viewModel.firstName) && StringUtils.isNotNullOrEmpty(viewModel.lastName)}"
5 | android:onClick="@{() -> viewModel.buttonClicked()}"
6 | android:text="@string/btn_hello_rx" />
在第4行代码处的enabled属性的值为true还false依赖于viewModel的firstName和lastName的值。这样写代码虽然能够正常的工作，但还是有一些缺点。
- 针对这个绑定表达式你不能够编写单元测试
- 在不同的XML布局文件中,这个绑定表示式的重用性较低
- 表达式太长，可读性差，他应该被放在.java文件中。
下面是改进后的例子：
1 | <Button
2 | android:layout_width="wrap_content"
3 | android:layout_height="wrap_content"
4 | android:enabled="@{viewModel.helloButtonEnabled}"
5 | android:onClick="@{() -> viewModel.buttonClicked()}"
6 | android:text="@string/btn_hello_rx" />
我们修改了第4行的代码，使得绑定表达式变得极其简单和易读。在ViewModel中我们创建绑定到view的enable属性的helloButtonEnabled ObservableField。在下边例子代码的第9行，我们组合了firstName和lastName的Observable。当firstName和lastName的值不为null或空字符串的时候helloButtonEnabled的值被设置成true，否则将helloButtonEnabled的值设置成false并将helloText的值清除。
1| public static class MainViewModel {
2|
3| public ObservableField<String> firstName = new ObservableField<>();
4| public ObservableField<String> lastName = new ObservableField<>();
5| public ObservableField<String> helloText = new ObservableField<>();
6| public ObservableBoolean helloButtonEnabled = new ObservableBoolean(false);
7| public MainViewModel() {
8|
9| Observable.combineLatest(toObservable(firstName), toObservable(lastName), (firstName, lastName) -> StringUtils.isNotNullOrEmpty(firstName) && StringUtils.isNotNullOrEmpty(lastName))
10| .subscribe(result -> {
11| helloButtonEnabled.set(result);
12| if (!result) {
13| helloText.set(StringUtils.EMPTY);
14| }
15|
16| }, Throwable::printStackTrace);
17|
18| }
19|
20| public void buttonClicked() {
21| helloText.set(String.format("Hello %s %s !", 22|firstName.get(),lastName.get()));
23| }
24| }
现在我们可以对计算helloButtonEnabled值的逻辑编写单元测试并将这个值绑定到enable属性中。
1| public class MainViewModelTests {
2|
3| @Test
4| public void mainViewModel_firstName_lastName_helloButtonEnabledSetToTrue() throws Exception {
5| MainViewModel mainViewModel = new MainViewModel();
6|
7| assertFalse(mainViewModel.helloButtonEnabled.get());
8|
9| mainViewModel.firstName.set("a");
10| mainViewModel.lastName.set("b");
11|
12| assertTrue(mainViewModel.helloButtonEnabled.get());
13|
14| }
15|
16| @Test
17| public void mainViewModel_firstName_lastNameEmpty_helloButtonEnabledSetToFalse() throws Exception {
18| MainViewModel mainViewModel = new MainViewModel();
19|
20| mainViewModel.firstName.set("a");
21| mainViewModel.lastName.set("");
22|
23| assertFalse(mainViewModel.helloButtonEnabled.get());
24|
25| }
26|
27| }
这种解决方案的好处：
- 重要的逻辑被放在了ViewModel中
- 方便编写单元测试
- XML布局文件更加可读
- 没有重复的代码
在Android Data Binding中使用RxJava是非常容易的，使用ObservableField的addOnPropertyChangedCallback方法注册OnPropertyChangedCallback。当observable属性改变的时候这个回调将会被android.databinding.Observable调用。利用这些知识我们可以使用RxJava包装它，然后在需要使用的地方进行调用。
1| public static <T> Observable<T> toObservable(@NonNull final ObservableField<T> observableField) {
2|
3| return Observable.create(new Observable.OnSubscribe<T>() {
4| @Override
5| public void call(final Subscriber<? super T> subscriber) {
6|
7| if (!subscriber.isUnsubscribed()) {
8| subscriber.onNext(observableField.get());
9| }
10|
11| final OnPropertyChangedCallback callback = new OnPropertyChangedCallback() {
12| @Override
13| public void onPropertyChanged(android.databinding.Observable dataBindingObservable, int propertyId) {
14| if (dataBindingObservable == observableField) {
15| subscriber.onNext(observableField.get());
16| }
17| }
18| };
19|
20| observableField.addOnPropertyChangedCallback(callback);
21|
22| subscriber.add(Subscriptions.create(new Action0() {
23| @Override
24| public void call() {
25| observableField.removeOnPropertyChangedCallback(callback);
26| }
27| }));
28| }
29| });
30| }
在Android Data Binding中使用RxJava能够改善你的代码的质量和可读性。但是需要注意在某些场景下他可能会导致过渡设计。
本篇博文就告一段落了，由于本人水平有限，如果写得不好还请见谅如果你有任何问题欢迎提出。
本文的源码地址：https://github.com/chenyi2013/android-data-binding-rxjava
本文内容均参考自：https://medium.com/tangoagency/rxjava-meets-android-data-binding-4ca5e1144107#.9xdo99szj
