Нет исключения MissingBackpressureException с Flowable.interval и цепочкой блокировки - PullRequest
0 голосов
/ 10 апреля 2019

Рассмотрим следующий пример:

fun main() {
  Flowable.interval(1, TimeUnit.MILLISECONDS).map {
    Thread.sleep(1000)
    it
  }.blockingForEach { println(it) }
}

При отсутствии обратного давления я бы ожидал получить MissingBackpressureException, как написано в документах Flowable.interval.

Что яошибаешься?

...