В RxJava есть такая штука - Subject - он одновременно является Observable и Observer - то есть он может эмитить сообщения как Observer, и в то же время на него можно подписаться (ибо Observable)
Есть что то похожее в reactor? Я так понимаю, в его терминах - он должен реализовать одновременно как FluxSink так и сам Flux.
