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

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

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

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

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

BlockingObservable的方法

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

要將一個Observable轉(zhuǎn)換為一個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ā)射物，使用無參數(shù)的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方法傳遞一個謂詞函數(shù)用于獲取滿足條件的BlockingObservable。

• Javadoc: BlockingObservable.first(Func1)

firstOrDefault

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

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

• Javadoc: BlockingObservable.firstOrDefault()

firstOrDefault.p

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

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

• Javadoc: BlockingObservable.firstOrDefault(T, Func1)

single

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

single和first類似，但是如果不是正好發(fā)射一個數(shù)據(jù)，會拋出異常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" />

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

• 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，接受一個謂詞函數(shù)，如果沒有復(fù)合條件的，返回默認值；如果有多個復(fù)合條件的，以錯誤通知終止。

• Javadoc: singleOrDefault(Func1,T)

next

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

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

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

• 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ā)射任何數(shù)據(jù)），或者是BlockingObservable最近發(fā)射的數(shù)據(jù)項。

• Javadoc: mostRecent(T)

forEach

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

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

• Javadoc: BlockingObservable.forEach(Action1)

參見：

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

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