我在例子中没有看到的一件事是，当你通过asObservable将BehaviorSubject转换为Observable时，它继承了订阅时返回最后一个值的行为。

这是很棘手的一点，因为库通常会将字段作为可观察对象公开(例如，在Angular2中ActivatedRoute中的参数)，但可能会在幕后使用Subject或BehaviorSubject。他们使用什么会影响订阅行为。

请看这里http://jsbin.com/ziquxapubo/edit?html,js,console

let A = new Rx.Subject();
let B = new Rx.BehaviorSubject(0);

A.next(1);
B.next(1);

A.asObservable().subscribe(n => console.log('A', n));
B.asObservable().subscribe(n => console.log('B', n));

A.next(2);
B.next(2);

我在例子中没有看到的一件事是，当你通过asObservable将BehaviorSubject转换为Observable时，它继承了订阅时返回最后一个值的行为。

这是很棘手的一点，因为库通常会将字段作为可观察对象公开(例如，在Angular2中ActivatedRoute中的参数)，但可能会在幕后使用Subject或BehaviorSubject。他们使用什么会影响订阅行为。

请看这里http://jsbin.com/ziquxapubo/edit?html,js,console

let A = new Rx.Subject();
let B = new Rx.BehaviorSubject(0);

A.next(1);
B.next(1);

A.asObservable().subscribe(n => console.log('A', n));
B.asObservable().subscribe(n => console.log('B', n));

A.next(2);
B.next(2);

把Observables想象成一个管道，里面有流动的水，有时水流动，有时不流动。在某些情况下，你可能真的需要一个一直有水的管道，你可以通过创建一个特殊的管道来做到这一点，不管它有多小，让我们把这个特殊的管道称为行为主题，如果你恰好是你所在社区的供水供应商，你可以安心地睡在晚上，因为你新安装的管道只是工作。

在技术术语中:你可能会遇到一个可观察对象总是有价值的情况，也许你想要捕获输入文本的值，然后你可以创建一个BehaviorSubject的实例来确保这种行为，让我们说:

const firstNameChanges = new BehaviorSubject("<empty>");

// pass value changes.
firstNameChanges.next("Jon");
firstNameChanges.next("Arya");

然后，您可以使用“value”对随时间变化的更改进行抽样。

firstNameChanges.value;

这在你以后组合可观察对象时很方便，通过查看你的流的类型为BehaviorSubject，你可以确保流至少会触发或发出至少一次信号。

BehaviorSubject

BehaviorSubject构建在与我们的ReplaySubject相同的功能之上，比如，hot，并重放先前的值。

BehaviorSubject又增加了一个功能，您可以给BehaviorSubject一个初始值。让我们继续，看看这段代码

import { ReplaySubject } from 'rxjs';

const behaviorSubject = new BehaviorSubject(
  'hello initial value from BehaviorSubject'
);

behaviorSubject.subscribe(v => console.log(v));

behaviorSubject.next('hello again from BehaviorSubject');

观察

首先，我们来看看创建常规Observable的最小API。有几种方法可以创建Observable。创建Observable的方法是实例化类。其他操作符可以简化这个步骤，但我们希望将实例化步骤与不同的Observable类型进行比较

import { Observable } from 'rxjs';

const observable = new Observable(observer => {
  setTimeout(() => observer.next('hello from Observable!'), 1000);
});

observable.subscribe(v => console.log(v));

BehaviorSubject是一种类型的主题，主题是一种特殊类型的可观察对象，所以你可以像其他可观察对象一样订阅消息。行为主体的独特之处在于:

它需要一个初始值，因为它必须总是在订阅时返回一个值，即使它没有接收到next() 在订阅时，它返回主题的最后一个值。常规可观察对象只有在接收到onnext时才会触发 在任何时候，您都可以使用getValue()方法在不可观察的代码中检索主题的最后一个值。

与可观察对象相比，主体的独特特征是:

它是一个观察者，除了是一个可观察对象，所以你也可以发送值到一个主题，除了订阅它。

此外，你可以使用行为主体上的asObservable()方法从行为主体获取一个可观察对象。

Observable是一个泛型，而BehaviorSubject在技术上是Observable的子类型，因为BehaviorSubject是一个具有特定品质的可观察对象。

以行为主体为例:

// Behavior Subject

// a is an initial value. if there is a subscription 
// after this, it would get "a" value immediately
let bSubject = new BehaviorSubject("a"); 

bSubject.next("b");

bSubject.subscribe(value => {
  console.log("Subscription got", value); // Subscription got b, 
                                          // ^ This would not happen 
                                          // for a generic observable 
                                          // or generic subject by default
});

bSubject.next("c"); // Subscription got c
bSubject.next("d"); // Subscription got d

例2:常规主语:

// Regular Subject

let subject = new Subject(); 

subject.next("b");

subject.subscribe(value => {
  console.log("Subscription got", value); // Subscription won't get 
                                          // anything at this point
});

subject.next("c"); // Subscription got c
subject.next("d"); // Subscription got d

可以使用Subject . asobservable()从Subject和BehaviorSubject创建一个可观察对象。

唯一的区别是你不能使用next()方法将值发送到可观察对象。

在Angular服务中，我会为数据服务使用BehaviorSubject，因为Angular服务通常会在组件之前进行初始化，而behavior subject会确保使用该服务的组件接收到最后一次更新的数据，即使自该组件订阅该数据以来没有新的更新。

Observable对象表示一个基于推的集合。

观察者和可观察接口为基于推送的通知提供了一种通用机制，也称为观察者设计模式。Observable对象表示发送通知的对象(提供者);Observer对象表示接收它们的类(观察者)。

Subject类继承了Observable和Observer，也就是说它既是一个观察者又是一个可观察对象。您可以使用主题订阅所有观察者，然后将主题订阅到后端数据源

var subject = new Rx.Subject();

var subscription = subject.subscribe(
    function (x) { console.log('onNext: ' + x); },
    function (e) { console.log('onError: ' + e.message); },
    function () { console.log('onCompleted'); });

subject.onNext(1);
// => onNext: 1

subject.onNext(2);
// => onNext: 2

subject.onCompleted();
// => onCompleted

subscription.dispose();

更多信息https://github.com/Reactive-Extensions/RxJS/blob/master/doc/gettingstarted/subjects.md