语义因主题类型而异。我将它们分为两种：vanilla（Rx.Subject）和特殊用途主题（其他三种）。专用主题由于其专业性（例如，完成/重新连接行为）而具有一些共同之处，因此具有一些香草主题的部分语义。

Vanilla Rx.Subject语义

1. 主要特点

   • 主题实现观察者，可观察的界面（以及在dispose原型上具有处理程序的一次性界面）。这意味着，除其他外，它们具有：
   • 观察者接口：onNext，onError，onComplete方法
   • 可观察的界面：subscribe方法
   • 您可以将主题投射给观察者或可观察对象，如果需要，可以隐藏额外接口（参见.asObserver()和.asObservable()的实现。
   • 如果该主题是可观察的，则可以订阅多个观察者。然后，该可观察对象将向所有观察者广播其数据。在内部，主题保持着一组观察者。
   • 主题是观察者，您可以订阅任何可观察的对象
   • 组成主题的观察者和可观察对象是两个不同的实体，如果这是您的用例，则可以独立使用它们。
   • dispose设置主题将取消所有观察者的订阅并释放资源。
   • 主题不使用调度程序，而是假设所有序列化和语法正确性均由主题的调用者处理。
   • 主题的默认行为是将它们的值 同步 发送给观察者， 从第一个订阅的观察者到最后一个观察者开始 在大多数情况下，顺序并不重要，而在其他情况下，顺序却无关紧要。

我引用了Rxjs合约和语法的一个关键方面：

该语法允许可观察的序列将任何数量（0或更多）的onNext消息发送到订阅的观察者实例，还可以选择后跟单个成功（onCompleted）或失败（onError）消息。

• （由创建的new Rx.Subject()）香草主题实现了该语法：onCompleted被调用一次后，对的所有后续调用都将onNext被忽略。onCompleted同一观察者的第二次调用也将被忽略。如果观察者订阅了主题的可观察方，则其onComplete回调将立即被调用。

  1. 创建

  2. new Rx.Subject()

返回一个主题，该主题将其观察者与其可观察的对象连接起来。本示例摘自官方文档，并描绘了如何使用主题作为代理。该主题已订阅源（观察者侧），并且也被观察者（可观察侧）收听。对onNext（观察者端）的任何调用都会导致可观察端onNext为其每个观察者调用相同的值。

* `Rx.Subject.create(observer, observable)`

从指定的观察者创建一个可观察的主题。这两个不一定连接。可以看到一个很好的示例，该示例的实现Rx.Dom.fromWebSocket返回一个主题，该主题用于从套接字发送和接收数据。主题的观察者侧将数据发送到套接字。可观察端用于侦听来自套接字的传入数据。此外，以这种方式创建的主题没有dispose方法。

专门的Rx.Subject语义

• 该reactivex.io文档很好地涵盖了专业主题的大多数语义。
• 值得一提的其他有趣问题涉及完成后的行为。

希望我没有做错太多。我很乐意得到纠正。最后说明，这对于RxJS v4应该有效。