rx-java - RxJava : Blocking single vs Blocking first

Question

我永远无法理解 blockingSingle 之间的区别和 blockingFirst在 Observables在 RxJava 中。任何帮助将不胜感激。

Answer 1

来自 https://github.com/ReactiveX/RxJava/wiki/Blocking-Observable-Operators 的定义

first() — block until the Observable emits an item, then return the first item 
emitted by the Observable

single( ) — if the Observable completes after emitting a single item, return 
that item, otherwise throw an exception

听起来像 first()发出任何项目后立即返回，并且 single()等待 Observable 完成返回。