相关文章链接:
Subject
Subject是一种桥梁和代理,在ReactiveX的一些实现中,它既可以当作observer也可以当做Observable。因为它是一个observer,所以它可以订阅一个或多个Observable,同时因为它是一个Observable,它可以传递它观察到的事件,重新发送他们,它也可以发送新的事件。
当Subject订阅一个Observable时,它可以触发Observable发送事件(如果那是一个“cold” Observable,以为“cold” Observable会在被订阅之后开始发送信息)。这一特点可以让Subject成为一个“hot”Observable,这个“hot” Observable是一种原来“cold”Observable的变体。
有四种不同用途的的Subject,不是这四种Subject都会在ReactiveX的所有实现中出现,不同的语言都会有自己的命名规范,会略有不同。
AsyncSubject
AsyncSubject只发送由源Observable发送的最后一个事件,并且只在源Observable完成之后。(如果源Observable没有发送任何值,AsyncSubject也不会发送任何值。)
AsyncSubject会发送相同的值给所有observer。但是,如果源Observable被一个error中断了发送,AsyncSubject不会发送任何事件,而是会发送从源Observable传来的error提示。
BehaviorSubject
当一个observer订阅一个BehaviorSubject,它就开始发送最近由源Observable发送的事件(或者是还没有被发送的种子值/默认值)然后继续发送从源Observable接收到的其他事件。
如果源Observable被一个error中断,那么BehaviorSubject不会发送事件给后续的observer,但会传递给他们error的信息。
PublishSubject
PublishSubject仅仅发送在订阅之后由源Observable发送的数据。
PublishSubject一旦被建立就会立刻开始发送事件(除非你采取一些方法去阻止它),这种机制有丢失事件的风险,因为在Subject被创建和被监听之间有一定的时间间隔。如果你想保证所有的事件都可以被监听到的话,你有两种方法。第一种是用Create
方法(在发送之前检查是否所有observer已经订阅好了)。第二种方法是你可以使用ReplaySubject。
如果源Observable被一个error中断,PublishSubject将不会发送任何事件给后续的observer,但是它会传递error信息。
ReplaySubject
ReplaySubject发送源Observable的所有事件无论observer什么时候开始订阅。
也有一些版本的ReplaySubject会在缓存中的事件数达到一定的值时丢掉一些事件,或者在某一个时间段之后丢掉一些缓存的事件。
如果把ReplaySubject当做一个观察者,注意不要从多个线程中调用onNext方法(或者其他on方法),因为这样的调用会导致非序列,ReplaySubject可能会弄不清楚哪个时间应该首先被replay。