title: Not able to read All event from Merged Flux
body: <p>I am new to Project Reactor, I am trying to implement following use case.
  I want to merge 2 different flux and want to read all the event. But Thing is it seem my main thread is not waiting for all the event</p>
  <pre><code>    @Test
  public void testMerge() {
      Flux &lt;String&gt; stringFlux = Flux.fromIterable(Arrays.asList(&quot;A&quot;, &quot;B&quot;, &quot;C&quot;)).delayElements(Duration.ofSeconds(1)); // Flux&lt;String&gt;
      Flux &lt;String&gt; stringFlux1 = Flux.fromIterable(Arrays.asList(&quot;D&quot;, &quot;E&quot;, &quot;F&quot;)); // Flux&lt;String&gt;
      Flux &lt;String&gt; stringFlux2 = Flux.merge(stringFlux, stringFlux1).log();
      stringFlux2.subscribe();
  }
  </code></pre>
  <blockquote>
  <p>Output
  onNext Event D
  onNext Event E
  onNext Event F</p>
  </blockquote>
  <p>I am only able to recevie above 3 event, not all event.</p>
  <p>By observing this behavior, subscribe seems to be async operation so main thread is not waiting for its completion. I am trying to use reactor core lib in my project. Can anyone please help me with this. I want to read all event in some standard way like we do with Futures.</p>