Class StepExecutionIterator

    • Constructor Detail

      • StepExecutionIterator

        public StepExecutionIterator()
    • Method Detail

      • apply

        public abstract com.google.common.util.concurrent.ListenableFuture<?> apply​(com.google.common.base.Function<StepExecution,​Void> f)
        Finds all the ongoing StepExecution and apply the function. The control flow is inverted because a major use case (workflow) loads StepExecutions asynchronously (for example when workflow run is blocked trying to restore pickles.)
        Returns:
        ListenableFuture to signal the completion of the application.