Рассмотрим следующий пример:
fun main() {
Flowable.interval(1, TimeUnit.MILLISECONDS).map {
Thread.sleep(1000)
it
}.blockingForEach { println(it) }
}
При отсутствии обратного давления я бы ожидал получить MissingBackpressureException
, как написано в документах Flowable.interval
.
Что яошибаешься?