In the introduction of this chapter, we explained what reactive streams are, which elements form the standard, and how those elements are implemented in Java:
- TheFlow.Publisher interface: This interface represents a producer of items.
- TheFlow.Subscriber interface: This interface represents a consumer of items.
- TheFlow.Subscription interface: This interface represents the connection between a producer and a consumer. The class that implements it manages the item interchange between the producer and the consumer.
In addition to these three interfaces, we have the SubmissionPublisher class that implements the Flow.Publisher interface. It also uses an implementation of the Flow.Subscription interface. It implements the method of the Flow.Publisher interface that allows the subscription of consumers and also methods to send items to those consumers, so we only have to implement one or more classes that implement the Flow.Subscriber interface.
Let's look at...