docs: public static <T, X extends Throwable> Tuple3<CompletableFuture<Subscription>, Runnable, CompletableFuture<Boolean>> forEachX(
              final Stream<T> stream, final long x, final Consumer<? super T> consumerElement) {
          return forEachXEvents(stream, x, consumerElement, e -> {
          } , () -> {
          });
  
      }