code: public <T> PushableFutureStream<T> futureStream(final LazyReact s) {
  
          final Queue<T> q = createQueue();
          return new PushableFutureStream<T>(
                                                 q, s.fromStream(q.stream()));
  
      }
docs: Create a pushable FutureStream using the supplied ReactPool
  
  <pre>
  {@code
  
  PushableFutureStream<Integer> pushable = StreamSource.ofUnbounded()
  .futureStream(new LazyReact());
  pushable.getInput().add(100);
  pushable.getInput().close();
  
  
  assertThat(pushable.getStream().collect(CyclopsCollectors.toList()),
  hasItem(100));
  
  
  }</pre>
  
  
  
  @param s ReactPool to use to create the Stream
  @return a Tuple2 with a Queue&lt;T&gt; and LazyFutureStream&lt;T&gt; - add data to the Queue
  to push it to the Stream