框架【库】RxJavaRxJava + Retrofit

Android Rxjava:不一样的诠释

2018-10-14  本文已影响378人  Linhaojian

1.前言


2.目录

示意图

3.简介

示意图

4.原理浅析

4.1 生活例子

4.2 例子结合Rxjava

  public void create(){
      Observable.create(new ObservableOnSubscribe<String>() {
          @Override
          public void subscribe(ObservableEmitter<String> e) throws Exception {
              e.onNext("烤鸡一份");
              e.onNext("薯条一份");
              e.onNext("可乐一杯");
//                e.onError(new NullPointerException());
              e.onComplete();
          }
      }).subscribe(new Observer<String>() {
          @Override
          public void onSubscribe(Disposable d) {
              Log.e(TAG,"onSubscribe : 订阅成功");
          }

          @Override
          public void onNext(String s) {
              Log.e(TAG,"onNext : 接收事件  "+s);
              //按顺序得到:烤鸡一份、薯条一份、可乐一杯
          }

          @Override
          public void onError(Throwable e) {
              Log.e(TAG,"onError : 事件异常  "+e.toString());
          }

          @Override
          public void onComplete() {
              Log.e(TAG,"onComplete : 事件执行完毕  ");
          }
      });
  }

总结:
被观察者(Observable):通过订阅行为(subscribe())把事件按顺序发送到 观察者(Observer)。 观察者(Observer):按顺序接收到事件&做出响应反馈。


5.操作符

5.1创建操作符

5.2变换操作符

5.3合拼操作符

5.4过滤操作符

5.5条件操作符

5.6其他功能操作符


6.框架设计思想

示意图

7.总结

写技术文章初心

  • 技术知识积累
  • 技术知识巩固
  • 技术知识分享
  • 技术知识交流
上一篇下一篇

猜你喜欢

热点阅读