docs: public Stream<T> jdkStream(int closeScalingFactor){
          int cores = Runtime.getRuntime().availableProcessors();
          String par = System.getProperty("java.util.concurrent.ForkJoinPool.common.parallelism");
          int connected = par !=null ? Integer.valueOf(par) : cores;
          int update = 0;
          do{
              update = listeningStreams.get()+ connected*closeScalingFactor;
          }while(!listeningStreams.compareAndSet(listeningStreams.get(), update));
  
          return closingStream(this::get, new AlwaysContinue());
      }