Fix Flow.repeat(); add FlowContext.peek()

Author: hpehl

CHANGELOG.md

@@ -7,6 +7,18 @@ to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
 ## [Unreleased]
 
+### Added
+
+- Add `FlowContext.peek()` method to retrieve the object at the top of the stack without removing it.
+
+### Changed
+
+- Change `Repeat.DEFAULT_INTERVAL` to 0
+
+### Fixed
+
+- Fix `Flow.repeat()` for tasks that start own promises.
+
 ## [2.4.6] - 2026-01-20
 
 ### Fixed

flow/src/main/java/org/jboss/elemento/flow/FlowContext.java

@@ -117,6 +117,18 @@ public <T> void push(T value) {
         stack.push(value);
     }
 
+    /**
+     * Retrieves the object at the top of the stack without removing it.
+     *
+     * @param <T> The type of the object on top of the stack.
+     * @return The object at the top of the stack.
+     * @throws EmptyStackException if the stack is empty.
+     */
+    @SuppressWarnings("unchecked")
+    public <T> T peek() {
+        return (T) stack.peek();
+    }
+
     /**
      * Removes the object at the top of the stack and returns that object.
      *

flow/src/main/java/org/jboss/elemento/flow/Repeat.java

@@ -31,17 +31,17 @@ public interface Repeat<C extends FlowContext> extends Promisable<C>, Subscripti
     boolean DEFAULT_FAIL_FAST = true;
 
     /**
-     * By default, the interval between the iterations is 1 second.
+     * By default, no interval is used between the iterations.
      */
-    long DEFAULT_INTERVAL = 1_000;
+    long DEFAULT_INTERVAL = 0;
 
     /**
      * By default, the timeout for the loop is 10 seconds.
      */
     long DEFAULT_TIMEOUT = 10_000;
 
     /**
-     * By default, the number of iterations are infinite.
+     * By default, the number of iterations is infinite.
      */
     int DEFAULT_ITERATIONS = -1;
 

flow/src/main/java/org/jboss/elemento/flow/RepeatImpl.java

@@ -21,15 +21,14 @@
 import elemental2.promise.Promise.PromiseExecutorCallbackFn.RejectCallbackFn;
 import elemental2.promise.Promise.PromiseExecutorCallbackFn.ResolveCallbackFn;
 
-import static elemental2.dom.DomGlobal.clearInterval;
 import static elemental2.dom.DomGlobal.clearTimeout;
-import static elemental2.dom.DomGlobal.setInterval;
 import static elemental2.dom.DomGlobal.setTimeout;
 
 class RepeatImpl<C extends FlowContext> extends FlowRunner<C> implements Repeat<C> {
 
     private final Task<C> task;
     private Predicate<C> predicate;
+    private boolean finished;
     private boolean failFast;
     private long interval;
     private long timeout;
@@ -43,6 +42,7 @@ class RepeatImpl<C extends FlowContext> extends FlowRunner<C> implements Repeat<
         super(context, 1);
         this.task = task;
         this.predicate = __ -> true;
+        this.finished = false;
         this.failFast = DEFAULT_FAIL_FAST;
         this.interval = DEFAULT_INTERVAL;
         this.timeout = DEFAULT_TIMEOUT;
@@ -99,7 +99,7 @@ Promise<C> run() {
     }
 
     private void until(ResolveCallbackFn<C> resolve, RejectCallbackFn reject) {
-        intervalHandle = setInterval(__ -> {
+        if (!finished) {
             if (failFast && lastFailure != null) {
                 cancel(reject, lastFailure);
             } else {
@@ -110,6 +110,11 @@ private void until(ResolveCallbackFn<C> resolve, RejectCallbackFn reject) {
                             if (areWeDone(c)) {
                                 finish(resolve, c);
                             }
+                            if (interval != 0) {
+                                intervalHandle = setTimeout(__ -> until(resolve, reject), interval);
+                            } else {
+                                until(resolve, reject);
+                            }
                             return null;
                         })
                         .catch_(error -> {
@@ -120,7 +125,7 @@ private void until(ResolveCallbackFn<C> resolve, RejectCallbackFn reject) {
                             return null;
                         });
             }
-        }, interval);
+        }
     }
 
     // ------------------------------------------------------ helper methods
@@ -134,6 +139,7 @@ private boolean areWeDone(C context) {
     }
 
     private void finish(ResolveCallbackFn<C> resolve, C context) {
+        finished = true;
         cleanup();
         context.progress.finish();
         resolve.onInvoke(context);
@@ -145,7 +151,7 @@ private void cancel(RejectCallbackFn reject, String reason) {
     }
 
     private void cleanup() {
-        clearInterval(intervalHandle);
+        clearTimeout(intervalHandle);
         clearTimeout(timeoutHandle);
     }
 }

samples/flow/package-lock.json

@@ -17,7 +17,6 @@
 
 import org.jboss.elemento.IsElement;
 import org.jboss.elemento.flow.FlowStatus;
-import org.patternfly.component.help.HelperText;
 import org.patternfly.component.tooltip.Tooltip;
 
 import elemental2.dom.HTMLElement;
@@ -76,10 +75,7 @@ public void finish() {
 
     public void status(FlowStatus status) {
         switch (status) {
-            case NOT_STARTED:
-                progress.status(info);
-                break;
-            case IN_PROGRESS:
+            case NOT_STARTED, IN_PROGRESS:
                 progress.status(info);
                 break;
             case SUCCESS:
@@ -96,8 +92,4 @@ public void status(FlowStatus status) {
                 break;
         }
     }
-
-    public void addHelperText(HelperText helperText) {
-        progress.addHelperText(helperText);
-    }
 }