O'Reilly logo

Reactive Programming With Java 9 by Tejaswini Mandar Jog

Stay ahead with the world's most comprehensive technology and business learning platform.

With Safari, you learn the way you learn best. Get unlimited access to videos, live online training, learning paths, books, tutorials, and more.

Start Free Trial

No credit card required

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

With Safari, you learn the way you learn best. Get unlimited access to videos, live online training, learning paths, books, interactive tutorials, and more.

Start Free Trial

No credit card required