docs: public static <T, X extends Throwable> void forEach(final Stream<T> stream, final Consumer<? super T> consumerElement,
                                                          final Consumer<? super Throwable> consumerError, final Runnable onComplete) {
  
          val t2 = FutureStreamUtils.forEachEvent(stream, consumerElement, consumerError, onComplete);
          t2._2().run();
  
      }