title: How to dynamically add elements to reactor hot flux from another method?
body: <p>I have a data source service, which takes an observer as a parameter.</p>
  
  <pre><code>void subscribe(Consumer onEventConsumer);
  </code></pre>
  
  <p>I want to use flux as a response stream for RSocket.
  How can I do this?
  As I see it now, it should be something like</p>
  
  <pre><code>Flux&lt;T&gt; controllerMethod(RequestMessage mgs) {
     var flux = Flux.empty();
     dataSource.subscribe(event -&gt; flux.push(event));
     return flux;
  }
  </code></pre>
  
  <p>But I have big doubts that it's a proper solution, and I'm new in the reactive approach, I don't know what methods I should use here?</p>