官方文档链接:http://reactivex.io/documentation/subject.html 和 http://reactivex.io/documentation/scheduler.html
1.前言
有四种Subject分别为特定用例而设计,但并不是在所有的实现中都可以用,而且某些实现使用其它名称(例如,RxScala中有PublishSubject
,可以简单理解为Subject
)。
2.Subject
Subject是一种桥接或代理,在ReactiveX的某些实现中,能有效当作观察者和被观察者。因为它是观察者,可以订阅一个或多个被观察者;又因为它是被观察者,可以重新产生需要的事件(传递的过程)和产生新的事件。因为Subject订阅一个被观察者,将触发被观察者开始产生事件(前提它是冷类型,即等到被订阅才开始产生事件)。这可以导致Subject成为热类型被观察者,相对于普通冷类型而言。
参考的文章:
- To Use or Not to Use Subject from Dave Sexton’s blog
- Introduction to Rx: Subject
- 101 Rx Samples: ISubject and ISubject
- Advanced RxJava: Subject by Dávid Karnok
- Using Subjects by Dennis Stoyanov
3.AsyncSubject
AsyncSubject.png
AsyncSubject只当原始被观察者完成后,才仅仅传递最后一个原始事件。(如果原始被观察者不产生任何事件,AsyncSubject也不传递任何事件直接完成。)
AsyncSubject.png它也将传递相同的最终的事件给任何后来的观察者。但是,如果原始被观察者因为onError()
通知终止,AsyncSubject将不传递任何事件,除了简单传递原始被观察者的onError()
通知。
参考的文章:
4.BehaviorSubject
BehaviorSubject.png
当某个BehaviorSubject被一个观察者订阅了,它开始传递最近的原始事件(若没有产生任何事件,则是默认值),然后继续传递任何随后的原始事件。
BehaviorSubject.png但是,如果原始被观察者因为onError()
通知终止,BehaviorSubject将不会传递任何事件给随后的观察者,除了简单传递原始被观察者的onError()
通知。
参考的文章:
5.PublishSubject
PublishSubject.png
PublishSubject给观察者传递的只有那些订阅之后的原始事件。注意,PublishSubject可能创建后立即开始传递事件(除非已经采取措施预防),所以在它被创建到观察者订阅它之间的事件有丢失的风险。如果需要保证所有原始事件不丢失,可以使用create()
操作符创建被观察者,以便手动控制冷类型被观察者行为(开始产生事件之前,检查所有观察者已经订阅),或改用ReplaySubject。
如果原始被观察者因为onError()
通知终止,PublishSubject将不会传递任何事件给随后的观察者,除了简单传递原始被观察者的onError()
通知。
6.ReplaySubject
ReplaySubject.png
ReplaySubject将所有原始事件传递给任何观察者,不管观察者什么时候订阅。也用另一种ReplaySubject,一旦缓冲大小快要超过某个值时(或从正常产生事件开始,每经过特定时间段),将抛弃旧的事件。如果使用ReplaySubject作为观察者,注意不要在多线程中调用它的onNext()
(或其它on
)方法,因为可能导致同时(非顺序)被调用,违反被观察者规则,且令Subject不知道哪个事件或通知应该先重发。
参考的文章:
7.Scheduler
如果想要将多线程引入操作链,可以这样通知操作符(或特定被观察者)执行于特定线程。ReactiveX操作符的某些实现将Scheduler作为一个参数,从而通知操作符在特定线程执行它的某些或所有任务。默认情况下,在被观察者subscribe()
操作符被调用的那个线程上,执行对自己使用的操作链和通知自己的观察者。subscribeOn()
操作符通过指定被观察者应该执行的线程,observeOn()
操作符指定被观察者发送通知给自己的观察者的线程,来改变这种行为。
如本图所示,subscribeOn()
操作符不管在操作链的哪个位置被调用,都将指出被观察者开始执行的那个线程。observeOn()
操作符则相反,影响被观察者随后将使用的操作符所在线程。为此,可能在操作链不同的地方调用observeOn()
操作符多次,来改变那些操作符执行的线程。
参考的文章:
- Introduction to Rx: Scheduling and Threading
- Rx Workshop: Schedulers
- Using Schedulers by Dennis Stoyanov
8.总结
ReactiveX相关的知识点已经全部讲完了。通过这次翻译,我对RxJava有了更深的理解,希望大家看后也能有所收获。最后官网还提供了教程等资源以及如何实现自己所需的操作符:
网友评论