Summary

In this chapter, we explored Reactor execution models. We discovered that publisher and subscriber Reactive Streams are concurrency agnostic. Most of the operators in Reactor are also concurrency agnostic. Some operators, such as delayElements and timeout, do alter the concurrency behavior of a stream's execution. Reactor provides various schedulers, which can be used to control the execution behavior of the stream. We found out that these schedulers can be configured for various operators, such as publishOn and subscribeOn. Next, we discussed ParallelFlux, which can be configured, along with the available schedulers, to perform parallel processing. Finally, we discussed event broadcasting by using ConnectedFlux. Reactor presents replay and publishOn operators, to generate a ConnectedFlux from an existing Flux.