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 Summary

Modifier and Type	Method	Description
void	complete(T result)	Complete this flow normally.
default void	complete(T value, Throwable throwable)	Complete the flow with value / exception.
void	completeExceptionally(Throwable exc)	Complete this flow with an exception.
void	completeFrom(@NonNull ExecutionFlow<T> flow)	Complete this flow from the given flow.
static <T> DelayedExecutionFlow<T>	create()
boolean	isCancelled()	Check for cancellation.
void	onCancel(@NonNull Runnable hook)	Add a listener that is called if this flow or any downstream flow is cancelled.

Methods inherited from interface io.micronaut.core.execution.ExecutionFlow

cancel, completeTo, flatMap, map, onComplete, onErrorResume, putInContext, putInContextIfAbsent, then, timeout, toCompletableFuture, tryComplete, tryCompleteError, tryCompleteValue

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

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