The TopicProcessor type

TopicProcessor is a processor capable of working with multiple subscribers, using an event loop architecture. The processor delivers events from a publisher to the attached subscribers in an asynchronous manner, and honors backpressure for each subscriber by using the RingBuffer data structure. The processor is also capable of listening to events from multiple publishers. This is illustrated in the following diagram:

Unlike the processors that deliver events in an ordered manner, TopicProcessor is capable of delivering events to subscribers in a concurrent manner. This is governed by the number of threads created in ...

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.