code: public <T> PushableReactiveSeq<T> reactiveSeq() {
          final Queue<T> q = createQueue();
          return new PushableReactiveSeq<T>(
                                            q, q.stream());
      }
docs: Create a pushable {@link PushableReactiveSeq}
  
  <pre>
  {@code
  PushableReactiveSeq<Integer> pushable = StreamSource.ofUnbounded()
  .reactiveSeq();
  pushable.getInput()
  .add(10);
  
  on another thread
  pushable.getStream()
  .collect(CyclopsCollectors.toList()) //[10]
  
  
  }
  </pre>
  
  
  @return PushableStream that can accept data to push into a {@see cyclops2.stream.ReactiveSeq}
  to push it to the Stream