In this chapter, we explored the various kinds of processors that are available in Reactor. You learned that the DirectProcessor is the simplest processor, but it does not offer backpressure. We then discussed the functions and abilities of UnicastProcessor, EmmiterProcessor, ReplayProcessor, TopicProcessor, and WorkQueueProcessor. In the end, we familiarized ourselves with hot and cold publishers, ultimately using UnicastProcessor to convert a Fibonacci generator into a hot publisher.
Summary
Get Hands-On Reactive Programming with Reactor now with the O’Reilly learning platform.
O’Reilly members experience books, live events, courses curated by job role, and more from O’Reilly and nearly 200 top publishers.
