code: @SuppressWarnings("rawtypes")
      public static <T, R> Collector<T, ?, R> streaming(final Function<? super Stream<T>, R> streamingCollector) {
          return streaming((Supplier) queueSupplier, streamingCollector);
      }
docs: Note: Generally it's much slower than other {@code Collectors}.
  
  @param streamingCollector
  @return
  @see Stream#observe(BlockingQueue, Predicate, long)
  @see Stream#asyncCall(Try.Function)