docs: public static <T, X extends Throwable> Subscription forEach(final Stream<T> stream, final long x,
                                                                  final Consumer<? super T> consumerElement, final Consumer<? super Throwable> consumerError, final Runnable onComplete) {
          val t2 = FutureStreamUtils.forEachXEvents(stream, x, consumerElement, consumerError, onComplete);
          t2._2().run();
          return t2._1().join();
      }