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有了一个入门的学习和使用了。

参考资料