Hands-On Reactive Programming with Reactor

Summary

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 ...