相关文章链接：

1. RxSwift中的Observable
2. RxSwift 上手详解 —— 入门篇

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。

原文链接