关于android:Android进阶学习RxJava一观察者与被观察者

Rxjava入门第一篇，搞定 Observer 与 Observable 之间的关系

百度百科原文翻译：
RxJava – JVM响应式扩大Reactive Extensions 用于应用Java VM的可察看序列编写异步和基于事件的程序的库。
它扩大了观察者模式以反对数据和/或事件序列，并减少了运算符，使您能够申明性地组合序列，同时形象出对低级线程，同步，线程安全性，并发数据结构和非线程等事物的关注阻塞I / O

装置 app上面build.gradle 退出两行，而后编译

   implementation 'io.reactivex:rxjava:1.1.1'
   implementation 'io.reactivex:rxandroid:1.0.1'

介绍

观察者：Observer
被观察者：Observable
两者创立关联：subscribe()

观察者

• 创立一个观察者(名字很陌生难了解，举例说明)

  • eg.
  • 观察者小明打算进来走走，多看看里面的世界

Observer<String> observer = new Observer<String>() {
    @Override //小明的第一个反馈，采取某种口头， 或者心潮澎湃 ，执行 onCompleted办法
    public void onCompleted() {
        LogUtils.e("Completed");
    }
    @Override //小明的第二个反馈，Pass 心田毫无波澜 下一位  ,执行 onNext办法
    public void onError(Throwable e) {
        LogUtils.e("Error");
    }
    @Override //小明的第三个反馈，Oh..NO  MyGod  WC ... 执行 onError 办法
    public void onNext(String s) {
        LogUtils.e(s);
    }
};

被观察者

• 创立一个被观察者(聪慧且百变的被观察者)

  • 此被观察者具备变动能力，能变成三种状态

    • A 一个丑陋的小姐姐
    • B 一个平铺直叙如同路人一样的人
    • C 一个猥琐的伪娘
  • 创立被观察者 小花

Observable observable1 = Observable.create(new Observable.OnSubscribe<String>() {
    @Override
    public void call(Subscriber<? super String> subscriber) {
        subscriber.onCompleted(); //被观察者小花变成A状态
    }
});
Observable observable1 = Observable.create(new Observable.OnSubscribe<String>() {
    @Override
    public void call(Subscriber<? super String> subscriber) {
        subscriber.onNext("Hello"); //被观察者小花变成B状态
    }
});
Observable observable1 = Observable.create(new Observable.OnSubscribe<String>() {
    @Override
    public void call(Subscriber<? super String> subscriber) {
        subscriber.onError("Wrold");//被观察者小花变成C状态
    }
});

• 最要害的一步(创立小明Observer和小花Observable的关系)

  • 让小花和小明一起走在林荫道上

observable1.subscribe(observer);

整体串起来是这样

• 小明来到了里面的世界，走在林荫道上

  • 正要仔细观察世界，遇到了小花(subscribe)

小花变成A状态(一个丑陋的小姐姐)

• 小明决定采取某种口头， 或者心潮澎湃 ，而后执行 onCompleted办法

小花变成B状态(一个平铺直叙如同路人一样的人)

• 小明….Pass 下一位 而后执行 onNext办法

小花变成C状态(一个猥琐的伪娘)

• 小明 Oh..NO MyGod WC … CCC 执行 onError 办法

总结

• 关键点是两者须要产生连贯，如果没有连贯，rxjava就没用了