なるほど、Backpressure制御かな https://github.com/ReactiveX/RxJava/wiki/Backpressure

RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM. - ReactiveX/RxJava

4:37 AM

Publisherという名前からも、Reactive Streamsに寄せている感じがある https://www.reactive-streams.org/ (edited)

4:38 AM

値を受け取る下流の方で、リソースなど何らかの都合で今はこれだけしか処理できないから送りすぎないでくれ、って上流に伝えるという感じ (edited)

4:39 AM

Demand.unlimited ならいくらでもOK