Из DirectProcessor , пружинный реактор 3.x документация:
Отправляет сигналы onNext, onError и onComplete подписчикам от нуля до многих. Обратите внимание, что наряду с несколькими потребителями текущая реализация DirectProcessor поддерживает несколько производителей. Однако все производители должны создавать сообщения в одном и том же потоке, в противном случае контракт Reactive Streams Spe c нарушается.
Что такое производитель в приведенной выше декларации?
- a
Publisher получение DirectProcessor в качестве параметра для Publisher.subscribe метод - что-то, вызывающее
DirectProcessor.onNext(T t) - что-то вызов
FluxSink<T>.next(T t), где FluxSink - результат DirectProcessor.sink()