考虑以下示例:
fun main() {
Flowable.interval(1, TimeUnit.MILLISECONDS).map {
Thread.sleep(1000)
it
}.blockingForEach { println(it) }
}
MissingBackpressureException
不要错过背压,我希望得到Flowable.interval
.
我怎么了?
考虑以下示例:
fun main() {
Flowable.interval(1, TimeUnit.MILLISECONDS).map {
Thread.sleep(1000)
it
}.blockingForEach { println(it) }
}
MissingBackpressureException
不要错过背压,我希望得到Flowable.interval
.
我怎么了?