首页 > 解决方案 > `Flowable.interval`和阻塞链没有`MissingBackpressureException`异常

问题描述

考虑以下示例:

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

MissingBackpressureException不要错过背压,我希望得到Flowable.interval.

我怎么了?

标签: rx-java2rx-kotlin2

解决方案


推荐阅读