关于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 就没用了