The behavior of the Publisher-Processor-Subscriber system

The following figure describes the mechanism of publishing the items by the Publisher to the Processor via Subscription, processing them, and publishing them to the Subscriber:

We already have discussed SubmissionPublisher, which publishes the items of type Long between the given range. What if we want to filter and get items divisible by 5? Yes, we will develop a processor to understand this better. Follow the steps to develop a Processor that we later will use for processing the elements. We will use the same project created in the earlier demos:

  1. Create a class and name it WelcomeProcessor ...

Get Reactive Programming With Java 9 now with O’Reilly online learning.

O’Reilly members experience live online training, plus books, videos, and digital content from 200+ publishers.