0

考虑以下示例:

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

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

我怎么了?

4

0 回答 0