Package software.amazon.lambda.durable

Interface ParallelDurableFuture

All Superinterfaces:

AutoCloseable, DurableFuture<ParallelResult>, SafeCloseable

All Known Implementing Classes:

ParallelOperation

public interface ParallelDurableFuture
extends SafeCloseable, DurableFuture<ParallelResult>

User-facing context for managing parallel branch execution within a durable function.

Method Summary

Modifier and Type	Method	Description
default <T> DurableFuture<T>	branch(String name, Class<T> resultType, Function<DurableContext,T> func)	Registers and immediately starts a branch (respects maxConcurrency).
default <T> DurableFuture<T>	branch(String name, Class<T> resultType, Function<DurableContext,T> func, ParallelBranchConfig config)	Registers and immediately starts a branch (respects maxConcurrency).
default <T> DurableFuture<T>	branch(String name, TypeToken<T> resultType, Function<DurableContext,T> func)	Registers and immediately starts a branch (respects maxConcurrency).
<T> DurableFuture<T>	branch(String name, TypeToken<T> resultType, Function<DurableContext,T> func, ParallelBranchConfig config)	Registers and immediately starts a branch (respects maxConcurrency).

Methods inherited from interface software.amazon.lambda.durable.DurableFuture

get

Methods inherited from interface software.amazon.lambda.durable.model.SafeCloseable

close

Method Details

branch

default <T> DurableFuture<T> branch(String name,
 Class<T> resultType,
 Function<DurableContext,T> func)

Registers and immediately starts a branch (respects maxConcurrency).

Type Parameters:

T - the result type

Parameters:

name - the branch name

resultType - the result type token for generic types

func - the function to execute in the branch's child context

Returns:

a DurableFuture that will contain the branch result

Throws:

IllegalStateException - if called after SafeCloseable.close()

branch

default <T> DurableFuture<T> branch(String name,
 TypeToken<T> resultType,
 Function<DurableContext,T> func)

Registers and immediately starts a branch (respects maxConcurrency).

Type Parameters:

T - the result type

Parameters:

name - the branch name

resultType - the result type token for generic types

func - the function to execute in the branch's child context

Returns:

a DurableFuture that will contain the branch result

Throws:

IllegalStateException - if called after SafeCloseable.close()

branch

default <T> DurableFuture<T> branch(String name,
 Class<T> resultType,
 Function<DurableContext,T> func,
 ParallelBranchConfig config)

Registers and immediately starts a branch (respects maxConcurrency).

Type Parameters:

T - the result type

Parameters:

name - the branch name

resultType - the result type token for generic types

func - the function to execute in the branch's child context

Returns:

a DurableFuture that will contain the branch result

Throws:

IllegalStateException - if called after SafeCloseable.close()

branch

<T> DurableFuture<T> branch(String name,
 TypeToken<T> resultType,
 Function<DurableContext,T> func,
 ParallelBranchConfig config)

Registers and immediately starts a branch (respects maxConcurrency).

Type Parameters:

T - the result type

Parameters:

name - the branch name

resultType - the result type token for generic types

func - the function to execute in the branch's child context

Returns:

a DurableFuture that will contain the branch result

Throws:

IllegalStateException - if called after SafeCloseable.close()