## Subscribe 操作來自Observable的發射物和通知 `Subscribe`操作符是連接觀察者和Observable的膠水。一個觀察者要想看到Observable發射的數據項，或者想要從Observable獲取錯誤和完成通知，它首先必須使用這個操作符訂閱那個Observable。 `Subscribe`操作符的一般實現可能會接受一到三個方法（然后由觀察者組合它們），或者接受一個實現了包含這三個方法的接口的對象（有時叫做`Observer`或`Subscriber`）： **`onNext`** 每當Observable發射了一項數據它就會調用這個方法。這個方法的參數是這個Observable發射的數據項。 **`onError`** Observable調用這個方法表示它無法生成期待的數據或者遇到了其它錯誤。這將停止Observable，它在這之后不會再調用`onNext`或`onCompleted`。`onError`方法的參數是導致這個錯誤的原因的一個表示（有時可能是一個Exception或Throwable對象，其它時候也可能是一個簡單的字符串，取決于具體的實現）。 **`onCompleted`** 如果沒有遇到任何錯誤，Observable在最后一次調用`onCompleted`之后會調用這個方法。 如果一個Observable直到有一個觀察者訂閱它才開始發射數據項，就稱之為"冷"的Observable；如果一個Observable可能在任何時刻開始發射數據，就稱之為"熱"的Observable，一個訂閱者可能從開始之后的某個時刻開始觀察它發射的數據序列，它可能會錯過在訂閱之前發射的數據。 RxJava中的實現是`subscribe`方法。 如果你使用無參數的版本，它將觸發對Observable的一個訂閱，但是將忽略它的發射物和通知。這個操作會激活一個"冷"的Observable。 你也可以傳遞一到三個函數給它，它們會按下面的方法解釋： 1. `onNext` 2. `onNext`和`onError` 3. `onNext`, `onError`和`onCompleted` 最后，你還可以傳遞一個`Observer`或`Subscriber`接口給它，`Observer`接口包含這三個以`on`開頭的方法。`Subscriber`接口也實現了這三個方法，而且還添加了幾個額外的方法，用于支持使用反壓操作(`reactive pull backpressure`)，這讓`Subscriber`可以在Observable完成前取消訂閱。 `subscribe`方法返回一個實現了`Subscription`接口的對象。這個接口包含`unsubscribe`方法，任何時刻你都可以調用它來斷開`subscribe`方法建立的Observable和觀察者之間的訂閱關系。 * Javadoc: [subscribe()](http://reactivex.io/RxJava/javadoc/rx/Observable.html#subscribe()) * Javadoc: [subscribe(Action1)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#subscribe(rx.functions.Action1)) * Javadoc: [subscribe(Action1,Action1)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#subscribe(rx.functions.Action1,%20rx.functions.Action1)) * Javadoc: [subscribe(Action1,Action1,Action0)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#subscribe(rx.functions.Action1,%20rx.functions.Action1,%20rx.functions.Action0)) * Javadoc: [subscribe(Observer)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#subscribe(rx.Observer)) * Javadoc: [subscribe(Subscriber)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#subscribe(rx.Subscriber)) ### foreach `forEach`方法是簡化版的`subscribe`，你同樣可以傳遞一到三個函數給它，解釋和傳遞給`subscribe`時一樣。 不同的是，你無法使用`forEach`返回的對象取消訂閱。也沒辦法傳遞一個可以用于取消訂閱的參數。因此，只有當你明確地需要操作Observable的所有發射物和通知時，你才應該使用這個操作符。 * Javadoc: [forEach(Action1)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#forEach(rx.functions.Action1)) * Javadoc: [forEach(Action1,Action1)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#forEach(rx.functions.Action1,%20rx.functions.Action1)) * Javadoc: [forEach(Action1,Action1,A/Users/mcxiaoke/github/RxDocs/docs/BlockingObservable.mdction0)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#forEach(rx.functions.Action1,%20rx.functions.Action1,%20rx.functions.Action0)) ### BlockingObservable `BlockingObservable`類中也有一個類似的叫作`forEach`的方法。詳細的說明見 [`BlockingObservable `](../BlockingObservable.md)