官术网_书友最值得收藏!

Backpressure

In an ideal scenario, every message produced by the Producer is passed to the Subscriber as and when the message is produced without any delay. There is a chance that the Subscriber is unable to handle the messages at the same rate as they are produced and this can cramp its resources.

Backpressure is a method by which the Subscriber can tell the Producer to send messages at a slower rate to give the Subscriber time to handle these messages properly without putting too much pressure on its resources.

Since this is the first chapter, we are just introducing you to these important reactive concepts. Code examples will be covered in subsequent chapters.

Now that we have a brief idea of Reactive Streams and Reactive Streams Specification, we will go into next important reactive concept in Java, namely Reactive Extensions.

主站蜘蛛池模板: 武冈市| 新和县| 札达县| 阳谷县| 华宁县| 广安市| 封丘县| 宁陵县| 济宁市| 隆回县| 凤城市| 东光县| 布尔津县| 大城县| 南雄市| 文水县| 涪陵区| 临沂市| 滦南县| 鹰潭市| 兰考县| 互助| 罗江县| 南昌县| 正定县| 东兰县| 巴彦淖尔市| 松原市| 黄梅县| 伊吾县| 启东市| 双峰县| 剑阁县| 类乌齐县| 普洱| 韩城市| 双江| 通道| 嘉义县| 寻甸| 台南市|