javado c для DirectProcessor из реактора проекта говорит
Обратите внимание, что наряду с несколькими потребителями текущая реализация DirectProcessor поддерживает несколько производителей. Однако все производители должны создавать сообщения в одном потоке, иначе Reactive Streams Spe c контракт будет нарушен.
Означает ли это требование, что все onNext, onError, onComplete должны вызываться в том же потоке? Или это относится только к сообщениям, которые отправляются одновременно, без каких-либо событий между отправками? Глядя на реализацию процессора, кажется безопасным использовать его из нескольких потоков, если два сообщения никогда не отправляются одновременно.
Перефразируя вопрос, безопасно ли вызывать onNext из разных потоков, если между этими вызовами существует связь «произошло до»?