RxJava: Блокирование одного против Блокирования первым - PullRequest
0 голосов
/ 16 января 2019

Я никогда не мог понять разницу между blockingSingle и blockingFirst на Observables в RxJava. Любая помощь будет принята с благодарностью.

1 Ответ

0 голосов
/ 16 января 2019

определений от 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() ожидает завершения наблюдения, чтобы завершить.

...