EmitterProcessor - onNext или FluxSink

Question

С EmitterProcessor я могу использовать onNext или sink, чтобы получить FluxSink и использовать его.

EmitterProcessor<Long> emitterProcessor = EmitterProcessor.create(100);

// Option 1  
emitterProcessor.onNext(1L);

// Option 2
FluxSink fluxSink = emitterProcessor.sink();
fluxSink.next(1L);

Является ли один лучше другого, когда я должен использовать один над другим?

Спасибо.

Answer 1

Согласно документации Project Reactor (4.7.2), не используйте процессор напрямую. Вместо этого используйте фасад Sink для вывода значений.

Sink.next является потокобезопасным, используя который вы можете выдавать значения из нескольких потоков. onNext может вызвать проблемы. Итак, вариант 2 верен.