Динамически объединяемые потоки

Question

Я написал приложение с серверной стороны, применяющее шаблон Event Sourcing, со всеми входящими командами, обрабатываемыми последовательно с Reactor.Я получаю эти команды из клиентских подключений.Увы, мой Netty Pipeline публикует команды без уважения к Реактивному контракту.Reactor Netty может быть частью решения, потому что оно обеспечивает выполнение Reactive Contract вплоть до Netty Pipeline.

Но с Reactor Netty каждое соединение в Flux.Соединения добавляются и удаляются.

Как динамически объединить несколько Flux в один?Как циклически перебирать входящие потоки?

Answer 1

Я не совсем уверен, правильно ли я понял ваши вопросы, если вам нужен поток событий, события которого генерируются асинхронно, вы можете попробовать использовать реактор.core.publisher.TopicProcessor.В TopicProcessor мы создали стек, событие которого поступило из нескольких разных источников, и мы можем обработать его как один реактивный поток.

Я также новичок в реакторе-нетто, но ресурсов на сайте очень мало.Интернет, поэтому я хотел бы предоставить мое скромное мнение для вашей справки.