原文:
Rx.Observalbe.create()或者创建操作符，可以 创建（created） Observable流。
next()、error()和complete()可以向订阅者推送不同的通知。之后，执行过程可能被 处理掉（disposed） 。这四个方面都被集成在Observable实例当中，但是也有一些方面与其他类型有关，比如Observer和Subscription。 Observable的核心关注点是:
创建Observable流
订阅Observable流
执行Observable流
终止Observable流
创建Observable流
Rx.Observable.create可以说是Observable构造函数的别名，他可以接受一个参数:subscribe函数。
以下的例子创建了一个Observable流，每秒钟向Observer发出一个字符串类性值hi。
var observable = Rx.Observable.create(function subscribe(observer) { var id = setInterval(() => { observer.next('hi') }, 1000);}); Observables流可以使用
create()创建，但是通常我们会使用所谓的创建操作符，像of(),from(),interval()等等。
在上面的例子中，订阅函数(subscribe function)是描述Observalbe最重要的部分。那么，让我来看看何谓订阅。
订阅Observable流
在例子中，Observalbe的实例observable可以被订阅，像这样:
observable.subscribe(x => console.log(x));
也许你会注意到，observable.subscribe()和subscribe函数在Rx.Observable.create(function subscribe(observer){...})中使用了相同的名字，这并不是巧合。
Observable不在多个Observer之间共享subscribe。当调用observable.subscribe()并得到观察者时，在Rx.Observable.create(function subscribe(observer){...})中传入的函数将会被执行。每次执行observable.subscribe()都会触发一个单独针对当前Observer的运行逻辑。
订阅一个Observable流就像调用一个函数，流中的数据将会被传递给回调函数中。
一个subscribe函数被调用将会开启一个Observable执行流(Observable execution)，向观察者们输出流中的值或者事件。
执行Observable流
代码Rx.Observable.create(function subscribe(observer){...})代表了一个“Observable流”，由于惰性计算，只用当有Observer订阅流时，函数才会被执行。
有三个类型的值会在执行流中发出:
"Next"通知：发出一个值，比如数字，字符串，对象等等。"Error"通知:发出一个js错误或者异常。Complete通知：不发出任何值，表示流的结束。
Next通知是最重要也是最常用的类型：他代表了实际推送给Observer的值。Error和Complete通知只会在执行流中发出一次，要么是Error，要么是Complete。
用正表达式的规则可以很好的表达这种所谓的Observable语法和约定：
next*(error|complete)?
在一个Observable执行流中，会发出0到无限个
Next通知。而一旦Error或者Complete通知被发出，执行流将不会再推送任何消息。
下面的例子展示了一个推送了3个Next并Complete的流：
var observable = Rx.Observable.create(function subscribe(observer) { observer.next(1); observer.next(2); observer.next(3); observer.complete();}); Observables会严格遵守Observable约定，所以下面的代码将不会推送值4:
var observable = Rx.Observable.create(function subscribe(observer) { observer.next(1); observer.next(2); observer.next(3); observer.complete(); observer.next(4); // Is not delivered because it would violate the contract}); 在订阅函数中使用try/catch捕获可能抛出的异常，也是一个很不错的做法：
var observable = Rx.Observable.create(function subscribe(observer) { try { observer.next(1); observer.next(2); observer.next(3); observer.complete(); } catch (err) { observer.error(err); // delivers an error if it caught one }}); 终止Observable流
Observable流的执行时间线可能是无限长的，但通常我们只用到有限的时间段和观察者处理业务，因此，我们需要一种中断流执行的API。
由于一个执行过程对于每个Observer是独有的，一旦Observer接收到值，那么也必然需要一种中断执行的方式，从而可以节省计算性能和内存空间。当observable.subscribe()被调用，Observer将被附加到新创建的Observable执行过程中，同时返回了一个对象,Subscription：
var subscription = observable.subscribe(x => console.log(x));
Subscription代表了一个持续执行的过程，并且有一套最小化的API允许你中断流的执行过程。可以从这里进一步了解。以下例子展示了使用subscription.unsubscribe()中断持续执行的过程：
var observable = Rx.Observable.from([10, 20, 30]);var subscription = observable.subscribe(x => console.log(x));// Later:subscription.unsubscribe();
当你订阅流就可以获取一个Subscription，代表了持续执行的过程。调用
unsubscribe()就可以中断执行过程。
当我们使用create()创建一个Observable流时，每一个Observable都必须定义它如何处理获取到的资源的处理方式。你可以通过在subscribe()函数中返回一个自定义的unsubscribe函数，达到这个目的。
举个例子，以下展示了如何中断一个使用setInterval()执行interval的过程:
var observable = Rx.Observable.create(function subscribe(observer) { // Keep track of the interval resource var intervalID = setInterval(() => { observer.next('hi'); }, 1000); // Provide a way of canceling and disposing the interval resource return function unsubscribe() { clearInterval(intervalID); };}); 就像observable.subscribe()类似Observable.create(function subscribe(){..})一样，我们从subscribe()返回的unsubscribe()也概念性的等同于subscription.unsubscribe()。
function subscribe(observer) { var intervalID = setInterval(() => { observer.next('hi'); }, 1000); return function unsubscribe() { clearInterval(intervalID); };}var unsubscribe = subscribe({next: (x) => console.log(x)});// Later:unsubscribe(); // dispose the resources 我们使用Rx，包括Observable、Observer和Subscription，其原因就是为了使用这些安全(就如Observable约定的)和可组合的操作符。