Я исследовал API Java Flux, когда заметил, что из некоторых руководств можно подписаться только на одного издателя. Тем не менее, я вижу случай, когда полезно иметь несколько издателей на одну подписку: своего рода шина данных / сообщений.
Единственное решение, которое я нашел, - это инкапсуляция массива подписчиков и одного издателя внутри шины.
Мой вопрос: каков правильный подход с точки зрения реагирования на эту проблему?
Я заинтересован в том, чтобы решить эту проблему, внедрив собственных издателей / подписчиков и т. Д. (Используя API Java 9 java.util.concurrent.Flow). Этот проект предназначен для обучения, а не для производства.