RxJava使用小结之入门篇（一）
2016-07-21 本文已影响166人
sugaryaruan
在Java的世界里，接口是Java最强大的设计之一。笔者对接口的认识和理解包括：
实现一个接口需要四个步骤
- 接口定义：使用interface，可以外部定义，也可以在类中定义，根据实际需求来。
- 接口调用：接口定义好了，需要调用接口方法
- 接口实现：接口里的方法是抽象方法，需要开发人员具体的逻辑实现
- 接口注入：把接口实现的引用传给接口调用方。
接口的作用和意义：
- 通过入参，确定了一种数据流的流动方向，从接口调用方流向接口实现方。也即提供了一种代码执行的先后顺序。
- 降低代码的耦合。实现接口是java类与类之间的一种关系，比继承这样的强依赖的耦合度低。接口涉及Java六大设计原则里的依赖倒置原则和接口隔离原则，面向抽象编程，对调用者来说执行相同的行为（代码），却可以组织不同的逻辑。
- 作为静态常量的容器。可以在接口里定义各种常量。
在Android里的基本使用
Rxjava每一次observable发出事件，让订阅者执行，都是一次使用接口的过程，满足上述分析的四个步骤。
Observable.create()使用
EditText里输入内容，TextView显示
（1）Observable<String> observable = Observable.create(new Observable.OnSubscribe<String>() {
@Override
public void call(Subscriber<? super String> subscriber) {
subscriber.onStart();
String s = mainEd.getText().toString().trim();
subscriber.onNext(s);
subscriber.onCompleted();
}
});
（2）Subscriber<String> subscriber = new Subscriber<String>() {
@Override
public void onStart() {
super.onStart();
}
@Override
public void onCompleted() {
}
@Override
public void onError(Throwable e) {
}
@Override
public void onNext(String s) {
mainTv.setText(s);
}
};
（3）observable.subscribe(subscriber);
分析：
代码段（1）Observable.create()方法里，new Observable.OnSubscribe(),完成了subscriber接口的调用。
代码段（2）使用匿名内部类，完成了接口定义和接口实现。
代码段（3）完成了接口注入。
因此说，一次Rxjava的操作，就是一次使用接口的过程。明白了这点，如果以后引入Lambda表达式，也就不再容易感到困惑和不解了。
Observable.Just()使用
上述代码可以简化写成下面的样子
String trim = mainEd.getText().toString().trim();
Observable.just(trim).subscribe(new Action1<String>() {
@Override
public void call(String s) {
mainTv2.setText(s);
}
});
Just和Create生成Observable的关联和区别：
- just生成的Observable只调用了接口subscriber的onNext()和onComplited()。
- just代码执行是在订阅subscribe()方法调用之前，通过create生成的observable在订阅subscribe()方法调用的时候执行
Observable.from()使用
入参可以是集合或者数组，该集合或数组有多少个元素就会发送多少次事件。
StringBuilder sb = new StringBuilder();
ArrayList<String> list = new ArrayList<>();
list.add("step1");
list.add("step2");
list.add("step3");
list.add("step4");
Observable.from(list).subscribe(new Action1<String>() {
@Override
public void call(String s) {
sb.append(s+" ");
}
});
mainTv3.setText(sb.toString());
上述代码返回的结果是：step1 step2 step3 step4
小结
有了上述的认识和练习，相信对Rxjava有了一个入门的学习和使用了。
参考资料
