In this chapter, we discussed the flow control operators that are available in Reactor in detail. We looked at the different overload options that are available in the groupBy, buffer, and window operators. We then considered how we can throttle events using the sample operator, which allows only a single event to be delivered in the specified time interval. After that, we recapped the support for backpressure that is available in Reactor and studied the different overflow strategies that it provides. We also learned that Reactor uses the Overflow.Buffer strategy by default, which can be provided as part of the Flux.create API. Finally, we discussed the backpressure operators that can be used to alter the strategy of the producer ...

Get Hands-On Reactive Programming with Reactor now with O’Reilly online learning.

O’Reilly members experience live online training, plus books, videos, and digital content from 200+ publishers.