Hands-On Reactive Programming in Spring 5

Processors

The Reactive Streams specification defines the Processor interface. A Processor is a Publisher and a Subscriber at the same time. So, we can subscribe to a Processor instance and also manually send signals (onNext, onError, onComplete) to it. The authors of Reactor recommend omitting processors as they are hard to use and are prone to errors. In most cases, provided processors may be superseded by a combination of operators. Alternatively, a generator factory method (push, create, generate) may fit better for adapting external APIs.

Reactor proposes the following kinds of processors:

• Direct processors can only push data through manual user actions by operating with the processor's sink. DirectProcessor and UnicastProcessor are ...