code: public static <T, R> Collector<T, ?, R> streaming(final long maxWaitIntervalInMillis, final Supplier<? extends BlockingQueue<T>> queueSupplier,
              final Function<? super Stream<T>, R> streamingCollector) {
          final Function<Stream<T>, ContinuableFuture<R>> streamingCollector2 = new Function<Stream<T>, ContinuableFuture<R>>() {
              @Override
              public ContinuableFuture<R> apply(Stream<T> t) {
                  return t.asyncCall(streamingCollector);
              }
          };
  
          return streaming(queueSupplier, streamingCollector2, maxWaitIntervalInMillis);
      }
docs: Note: Generally it's much slower than other {@code Collectors}.
  
  @param maxWaitIntervalInMillis
  @param supplier
  @param streamingCollector
  @return
  @see Stream#observe(BlockingQueue, Predicate, long)
  @see Stream#asyncCall(Try.Function)