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