在RxJS中，Observable有一些特殊的类，在消息通信中使用比较频繁，下面主要介绍较常用的几个类：
类，Subject可以实现一个消息向多个订阅者推送消息，直接看代码实现吧
var subject = new (); //实例化一个Subject对象
(1); //向接受者发送一个消息流
({
next: (value) => ('observerA: ' + value) //接受者A订阅消息，获取消息流中的数据
});
({
next: (value) => ('observerB: ' + value) //接受者B订阅消息，获取消息流中的数据
});
这样两路接受者都能拿到发送的数据流：
observerA:1
observerB:1
是Subject的一个衍生类，它将数据流中的最新值推送给接受者
var subject = new (0); //声明一个BehaviorSubject对象
(1); //发送一个数据流
(2); //再发送一个数据流
({
next: (v) => ('observerA: ' + v) //接受者A订阅消息
});
({
next: (v) => ('observerB: ' + v) //接受者B订阅消息
});
(3); //再发送一个数据流
这样，每次接受者只会接受最新最送的那个消息：
observerA:2
observerB:2
observerA:3
observerB:3