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
Let's look at...