code: public <T> PushableStream<T> stream() {
          final Queue<T> q = createQueue();
          return new PushableStream<T>(
                                       q, q.jdkStream());
  
      }
docs: Create a pushable JDK 8 Stream
  
  <pre>
  {@code
  PushableStream<Integer> pushable = StreamSource.ofUnbounded()
  .stream();
  pushable.getInput()
  .add(10);
  pushable.getInput()
  .close();
  
  pushable.getStream().collect(CyclopsCollectors.toList()) //[10]
  
  
  }
  </pre>
  
  @return PushableStream that can accept data to push into a Java 8 Stream
  to push it to the Stream