BlockingObservable

這一節(jié)解釋 BlockingObservable 的子類. 一個阻塞的Observable 繼承普通的Observable類，增加了一些可用于阻塞Observable發(fā)射的數據的操作符。

要將普通的Observable 轉換為 BlockingObservable，可以使用 [Observable.toBlocking(?)](http://reactivex.io/RxJava/javadoc/rx/Observable.html#toBlocking()) 方法或者BlockingObservable.from(?) 方法。

• forEach(?) — 對Observable發(fā)射的每一項數據調用一個方法，會阻塞直到Observable完成
• first(?) — 阻塞直到Observable發(fā)射了一個數據，然后返回第一項數據
• firstOrDefault(?) — 阻塞直到Observable發(fā)射了一個數據或者終止，返回第一項數據，或者返回默認值
• last(?) — 阻塞直到Observable終止，然后返回最后一項數據
• lastOrDefault(?) — 阻塞直到Observable終止，然后返回最后一項的數據，或者返回默認值
• mostRecent(?) — 返回一個總是返回Observable最近發(fā)射的數據的iterable
• next(?) — 返回一個Iterable，會阻塞直到Observable發(fā)射了另一個值，然后返回那個值
• latest(?) — 返回一個iterable，會阻塞直到或者除非Observable發(fā)射了一個iterable沒有返回的值，然后返回這個值
• single(?) — 如果Observable終止時只發(fā)射了一個值，返回那個值，否則拋出異常
• singleOrDefault(?) — 如果Observable終止時只發(fā)射了一個值，返回那個值，否則否好默認值
• toFuture(?) — 將Observable轉換為一個Future
• toIterable(?) — 將一個發(fā)射數據序列的Observable轉換為一個Iterable
• getIterator(?) — 將一個發(fā)射數據序列的Observable轉換為一個Iterator

伴隨這個解釋還有一個修改版的彈珠圖，表示阻塞Observable的彈珠圖：

http://wiki.jikexueyuan.com/project/rx-docs/images/operators/B.legend.png" alt="BlockingObservables" />

BlockingObservable的方法

BlockingObservable的方法不是將一個Observable變換為另一個，也不是過濾Observables，它們會打斷Observable的調用鏈，會阻塞等待直到Observable發(fā)射了想要的數據，然后返回這個數據（而不是一個Observable）。

要將一個Observable轉換為一個BlockingObservable，你可以使用Observable.toBlocking或BlockingObservable.from方法。

• Javadoc: [Observable.toBlocking()](http://reactivex.io/RxJava/javadoc/rx/Observable.html#toBlocking())
• Javadoc: BlockingObservable.from(Observable)

first

http://wiki.jikexueyuan.com/project/rx-docs/images/operators/B.first.png" alt="first" />

要獲取BlockingObservable的發(fā)射物，使用無參數的first方法。

• Javadoc: [BlockingObservable.first()](http://reactivex.io/RxJava/javadoc/rx/observables/BlockingObservable.html#first())

first.p

http://wiki.jikexueyuan.com/project/rx-docs/images/operators/B.first.p.png" alt="first" />

你也可以給first方法傳遞一個謂詞函數用于獲取滿足條件的BlockingObservable。

• Javadoc: BlockingObservable.first(Func1)

firstOrDefault

http://wiki.jikexueyuan.com/project/rx-docs/images/operators/B.firstOrDefault.png" alt="firstOrDefault" />

和過濾操作符一樣，如果原始Observable沒有數據，first會拋出異常NoSuchElementException，firstOrDefault會返回一個默認值。

• Javadoc: BlockingObservable.firstOrDefault()

firstOrDefault.p

http://wiki.jikexueyuan.com/project/rx-docs/images/operators/B.firstOrDefault.p.png" alt="firstOrDefault" />

firstOrDefault同樣也接受一個謂詞函數作為參數，用于獲取滿足條件的第一項，如果沒有滿足條件的就返回默認值。

• Javadoc: BlockingObservable.firstOrDefault(T, Func1)

single

http://wiki.jikexueyuan.com/project/rx-docs/images/operators/B.single.png" alt="single" />

single和first類似，但是如果不是正好發(fā)射一個數據，會拋出異常NoSuchElementException。其它幾個變體的功能也是類似的。

• Javadoc: [single()](http://reactivex.io/RxJava/javadoc/rx/observables/BlockingObservable.html#single())

single.p

http://wiki.jikexueyuan.com/project/rx-docs/images/operators/B.single.p.png" alt="single" />

同上，接受一個謂詞函數，如果滿足條件的不是正好一個，會拋出異常。

• Javadoc: single(Func1)

singleOrDefault

http://wiki.jikexueyuan.com/project/rx-docs/images/operators/B.singleOrDefault.png" alt="single" />

類似firstOrDefault，在為空時返回默認值，超過一個就拋出異常。

• Javadoc: singleOrDefault(T)

singleOrDefault.p

http://wiki.jikexueyuan.com/project/rx-docs/images/operators/B.singleOrDefault.p.png" alt="single" />

類似firstOrDefault，接受一個謂詞函數，如果沒有復合條件的，返回默認值；如果有多個復合條件的，以錯誤通知終止。

• Javadoc: singleOrDefault(Func1,T)

next

http://wiki.jikexueyuan.com/project/rx-docs/images/operators/B.next.png" alt="next" />

next操作符會阻塞直到BlockingObservable返回另外一個值，然后它返回那個值。你可以重復調用這個方法從BlockingObservable獲取后續(xù)的數據項。以阻塞的方式高效的迭代獲取它的發(fā)射物。

latest操作符也是類似的，但是它不會阻塞等待下一個值，它立即返回最近發(fā)射的數據項，只在Observable還沒有發(fā)射任何數據時會阻塞。

• Javadoc: [next()](http://reactivex.io/RxJava/javadoc/rx/observables/BlockingObservable.html#next())
• Javadoc: [latest()](http://reactivex.io/RxJava/javadoc/rx/observables/BlockingObservable.html#latest())

mostRecent

http://wiki.jikexueyuan.com/project/rx-docs/images/operators/B.mostRecent.png" alt="mostRecent" />

mostRecent操作符讓你可以用類似的方式迭代一個BlockingObservable，但是它總是立即返回一個值，或者是默認值（如果BlockingObservable還沒有發(fā)射任何數據），或者是BlockingObservable最近發(fā)射的數據項。

• Javadoc: mostRecent(T)

forEach

BlockingObservable類中也有一個類似的叫作forEach的方法。要使用這個方法，你首先需要使用BlockingObservable.from方法或Observable.toBlocking操作符將原始Observable轉換為一個BlockingObservable。

BlockingObservable.forEach接受單個函數作為參數，這個函數的作用類似于普通Observable訂閱中的onNext函數。forEach自身會阻塞知道BlockingObservable完成，當它不阻塞時就是完成了，不是通過調用一個回調方法表示它完成了。如果遇到了錯誤它將拋出一個RuntimeException（而不是調用一個類似于onError的回調方法）。

• Javadoc: BlockingObservable.forEach(Action1)

參見：

• javadoc: BlockingObservable
• javadoc: toBlocking()
• javadoc: BlockingObservable.from()

附錄：相似的阻塞和非阻塞操作符列表