Package io.micronaut.core.execution

Interface DelayedExecutionFlow<T>

Type Parameters:
T - The type of this flow
All Superinterfaces:
ExecutionFlow<T>
public sealed interface DelayedExecutionFlow<T> extends ExecutionFlow<T>
ExecutionFlow that can be completed similar to a CompletableFuture.

  • Method Details

    • create

      static <T> DelayedExecutionFlow<T> create()

    • complete

      void complete(@Nullable T result)
      Complete this flow normally.
      Parameters:
      result - The result value

    • completeExceptionally

      void completeExceptionally(Throwable exc)
      Complete this flow with an exception.
      Parameters:
      exc - The exception

    • tryComplete

      boolean tryComplete(@Nullable T result)
      Complete this flow normally.
      Parameters:
      result - The result value
      Returns:
      false if this flow has already been completed

    • tryCompleteExceptionally

      boolean tryCompleteExceptionally(Throwable exc)
      Complete this flow with an exception.
      Parameters:
      exc - The exception
      Returns:
      false if this flow has already been completed

    • isCancelled

      boolean isCancelled()
      Check for cancellation.
      Returns:
      true iff this flow or any downstream flow has been cancelled
      Since:
      4.8.0

    • onCancel

      void onCancel(@NonNull @NonNull Runnable hook)
      Add a listener that is called if this flow or any downstream flow is cancelled.
      Parameters:
      hook - The hook to call on cancellation
      Since:
      4.8.0

    • completeFrom

      void completeFrom(@NonNull @NonNull ExecutionFlow<T> flow)
      Complete this flow from the given flow.
      Parameters:
      flow - The input flow
      Since:
      4.7.0

    • complete

      default void complete(T value, Throwable throwable)
      Complete the flow with value / exception.
      Parameters:
      value - The value
      throwable - The exception
      Since:
      4.7.0