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 ParallelFluxwhich can be configured, along with the available schedulers, to perform parallel processing. Finally, we discussed event broadcasting by using ConnectedFlux. Reactor presents ...

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.