-
Book Overview & Buying
-
Table Of Contents
-
Feedback & Rating

Java 9 Concurrency Cookbook, Second Edition
By :

Reactive streams (http://www.reactive-streams.org/) defines a mechanism to provide asynchronous stream processing with non-blocking back pressure.
Reactive streams are based on three elements:
Java 9 has included three interfaces--Flow.Publisher
, Flow.Subscriber
, and Flow.Subscription
--and a utility class, SubmissionPublisher
, to allow us to implement reactive stream applications.
In this recipe, you will learn how to implement your own reactive application using only three interfaces. Take into account that we will implement the expected behavior between the three elements. The publisher will only send elements to those subscribers who have requested them, and it will do this in a concurrent way. But you can modify this behavior easily by modifying the implementation of the methods.
The example of...