RxJava使用小结之入门篇（一）

在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的关联和区别：

1. just生成的Observable只调用了接口subscriber的onNext()和onComplited()。
2. 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有了一个入门的学习和使用了。

参考资料

深入浅出RxJava（一：基础篇）

Github:RxJava