Subject

Subject是ReactiveX某些实现中的一种可用的桥或代理，既充当observer又充当Observable。因为它是observer，所以可以订阅一个或多个Observable，并且因为它是Observable，所以可以通过发送观察到的元素来传递它们，还可以发出新的元素。

因为某个Subject订阅了一个Observable，它将触发Observable开始发出元素（如果Observable是“cold”的，也就是说，如果它在开始发出元素之前等待订阅）。这样可以使最终的Subject成为原始“cold”Observable的变体“hot”Observable。

也可以看看

• 戴夫·塞克斯顿的博客使用或者不使用Subject
• Rx简介：Subject
• 101个Rx例子：ISubject<T> and ISubject<T1,T2>
• 高级RxJava：Subject by Dávid Karnok
• 丹尼斯·斯托亚诺夫的使用Subject

Subject的种类

总共有四种Subject，是针对特定情况设计的。并非所有这些实现在所有实现中都可用，并且某些实现使用其他命名约定（例如，在RxScala中，这里所谓的“ PublishSubject”简称为“ Subject”）：

AsyncSubject

AsyncSubject发射由源Observable发出的最后的值（并且只有最后一个值），并且只有在源Observable完成之后。（如果源Observable不发出任何值，则AsyncSubject也将完成而不会发出任何值。）

AsyncSubject也将向所有后续observers发出相同的最终值。但是，如果源Observable因发生错误而终止，AsyncSubject将不会发出任何元素，而只会简单地传递来自源Observable的错误通知。

也可以看看

Rx简介：AsyncSubject

BehaviorSubject

当observer订阅BehaviorSubject时，它首先发出源Observable最近发出的元素（如果尚未发出，则为初始值/默认值），然后继续发出后来由源Observable发出的任何其他元素。 ）。

但是，如果源Observable因发生错误终止，BehaviorSubject它将不会向后续的观察者发出任何元素，而只会简单地传递来自源Observable的错误通知。

也可以看看

Rx简介：BehaviorSubject

PublishSubject

PublishSubject PublishSubject仅向observer发出由源Observable后续订阅时间发出的那些元素。

请注意，PublishSubject可能会在创建后立即开始发射元素（除非已采取措施来防止这种情况发生），因此存在这样的风险，即在创建Subject和observer订阅它的时间之间可能丢失一个或多个元素。如果需要保证从Observable源交付所有元素，则需要使用ObservableCreate以便手动重新引入“cold” Observable行为（在开始发射项目之前检查所有观察者是否已订阅） ，或改为使用ReplaySubject。

如果源Observable因发生错误终止，PublishSubject将不会向后续观察者发出任何元素，而只会简单地传递来自源Observable的错误通知。

ReplaySubject

ReplaySubject 向observer发出由源Observable发出的所有元素，无论observer何时订阅。

还有一些版本的ReplaySubject，一旦重播缓冲区增长到一定大小以上，或者自从最开始发出元素以来经过了指定的时间间隔，就会丢弃旧元素。

如果将ReplaySubject用作observer，请注意不要从多个线程中调用其onNext方法（或其他on方法），因为这可能导致同时（非顺序）调用，这违反了Observable约定，并在结果Subject中关于应先重播哪个元素或通知造成歧义。

也可以看看

Rx简介：ReplaySubject