title: Project reactor: collectList() doesn't work for Flux.create()
body: <p>Below example prints integers from 1 to 10 and a list of (7, 8, 9, 10)</p>
  
  <pre><code>public void streamCollect() {
  
      ConnectableFlux&lt;Integer&gt; connect = Flux.range(1, 10)
              .publish();
  
      connect.subscribe(v -&gt; System.out.println("1: " + v));
  
      connect
              .filter(number -&gt; number &gt; 6)
              .collectList()
              .subscribe(v -&gt; System.out.println("4: " + v));
  
      connect.connect();
  }
  </code></pre>
  
  <p>Result:</p>
  
  <p>1: 1</p>
  
  <p>1: 2</p>
  
  <p>1: 3</p>
  
  <p>1: 4</p>
  
  <p>1: 5</p>
  
  <p>1: 6</p>
  
  <p>1: 7</p>
  
  <p>1: 8</p>
  
  <p>1: 9</p>
  
  <p>1: 10</p>
  
  <p>4: [7, 8, 9, 10]</p>
  
  <p>Next example should produce the same result but instead prints out only numbers from 1 to 10 but no list. Why?</p>
  
  <pre><code>public void streamCollect() {
  
      ConnectableFlux&lt;Integer&gt; connect = Flux.&lt;Integer&gt;create(emitter -&gt; {
  
          Stream.of(1, 2, 3, 4, 5, 6, 7, 8, 9, 10)
                  .forEach(t -&gt; emitter.next(t));
      }).publish();
  
      connect.subscribe(v -&gt; System.out.println("1: " + v));
  
      connect
              .filter(number -&gt; number &gt; 6)
              .collectList()
              .subscribe(v -&gt; System.out.println("4: " + v));
  
      connect.connect();
  }
  </code></pre>
  
  <p>Result:</p>
  
  <p>1: 1</p>
  
  <p>1: 2</p>
  
  <p>1: 3</p>
  
  <p>1: 4</p>
  
  <p>1: 5</p>
  
  <p>1: 6</p>
  
  <p>1: 7</p>
  
  <p>1: 8</p>
  
  <p>1: 9</p>
  
  <p>1: 10</p>