Package software.amazon.lambda.durable.testing

Class AsyncExecution<O>

java.lang.Object

software.amazon.lambda.durable.testing.AsyncExecution<O>

public class AsyncExecution<O>
extends Object

Handle for an asynchronously executing durable function. Allows incremental polling and inspection of execution state.

Constructor Summary

Constructors

Constructor	Description
AsyncExecution(String executionArn, software.amazon.awssdk.services.lambda.LambdaClient lambdaClient, TypeToken<O> outputType, Duration pollInterval, Duration timeout)

Method Summary

Modifier and Type	Method	Description
String	getCallbackId(String operationName)	Get the callback ID for a callback operation.
String	getExecutionArn()	Get the execution ARN.
TestOperation	getOperation(String name)	Get details for a specific operation.
List<TestOperation>	getOperations()	Get all operations in the execution.
ExecutionStatus	getStatus()	Get current execution status.
boolean	hasCallback(String name)	Check if a callback operation with the given name exists and is started.
boolean	hasOperation(String name)	Check if an operation with the given name exists.
boolean	isComplete()	Check if execution has completed (succeeded or failed).
AsyncExecution<O>	pollUntil(Predicate<AsyncExecution<O>> condition)	Poll execution history until the given condition is met.
TestResult<O>	pollUntilComplete()	Poll until execution completes and return the final result.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AsyncExecution

public AsyncExecution(String executionArn,
 software.amazon.awssdk.services.lambda.LambdaClient lambdaClient,
 TypeToken<O> outputType,
 Duration pollInterval,
 Duration timeout)

Method Details

pollUntil

public AsyncExecution<O> pollUntil(Predicate<AsyncExecution<O>> condition)

Poll execution history until the given condition is met.

Parameters:

condition - predicate to test on each poll

Returns:

this execution for chaining

pollUntilComplete

public TestResult<O> pollUntilComplete()

Poll until execution completes and return the final result.

Returns:

test result with execution status and output

isComplete

public boolean isComplete()

Check if execution has completed (succeeded or failed).

hasOperation

public boolean hasOperation(String name)

Check if an operation with the given name exists.

hasCallback

public boolean hasCallback(String name)

Check if a callback operation with the given name exists and is started.

getCallbackId

public String getCallbackId(String operationName)

Get the callback ID for a callback operation.

Parameters:

operationName - name of the callback operation

Returns:

callback ID

Throws:

IllegalStateException - if no callback found for operation

getOperation

public TestOperation getOperation(String name)

Get details for a specific operation.

getOperations

public List<TestOperation> getOperations()

Get all operations in the execution.

getStatus

public ExecutionStatus getStatus()

Get current execution status.

getExecutionArn

public String getExecutionArn()

Get the execution ARN.