code: @Override
      public ReactiveSeq<T> stream() {
          listeningStreams.incrementAndGet(); //assumes all Streams that ever connected, remain connected
          return ReactiveSeq.fromStream(closingStream(this::get, new AlwaysContinue()));
      }
docs: @return Sequential Infinite (until Queue is closed) Stream of data from
  this Queue