Package com.koralix.stepfn.builder

Class StepFunctionBuilder<T,R>

java.lang.Object

com.koralix.stepfn.builder.StepFunctionBuilder<T,R>

Type Parameters:

T - the type of the input to the function

R - the type of the result of the function

public class StepFunctionBuilder<T,R>
extends Object

A builder for StepFunctions.

Since:

1.1.0

See Also:

• StepFunction

Method Summary

Modifier and Type	Method	Description
<V> AsyncStepFunction<T,V>	async(Supplier<ExecutorService> executorSupplier)	Creates a new AsyncStepFunction from this builder.
static <T, V> StepFunctionBuilder<T,V>	step(Function<Map<Step<?,?>,T>,Boolean> isComplete, BiFunction<T,Map<Step<?,?>,T>,V> apply)	Creates a new StepFunctionBuilder with the given initial step.
static <T, V> StepFunctionBuilder<T,V>	step(Function<T,V> apply)	Creates a new StepFunctionBuilder with the given initial step.
<V> SyncStepFunction<T,V>	sync()	Creates a new SyncStepFunction from this builder.
StepFunctionBuilder<T,R>	transition(Function<R,Boolean> condition, StepFunctionBuilder<R,?> nextStep)	Adds a transition to this builder.
<V> StepFunctionBuilder<T,R>	transition(Function<R,Boolean> condition, Function<R,V> mapper, StepFunctionBuilder<V,?> nextStep)	Adds a transition to this builder.

Methods inherited from class java.lang.Object

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

Method Details

step

public static <T,
V> StepFunctionBuilder<T,V> step(Function<Map<Step<?,?>,T>,Boolean> isComplete,
 BiFunction<T,Map<Step<?,?>,T>,V> apply)

Creates a new StepFunctionBuilder with the given initial step.

Type Parameters:

T - the type of the input to the function

V - the type of the result of the function

Parameters:

isComplete - a function that returns true if the step is complete. Used for aggregating steps.

apply - the function to apply to the input

Returns:

a new StepFunctionBuilder

Since:

1.1.1

See Also:

• StepFunction

step

public static <T,
V> StepFunctionBuilder<T,V> step(Function<T,V> apply)

Creates a new StepFunctionBuilder with the given initial step.

Type Parameters:

T - the type of the input to the function

V - the type of the result of the function

Parameters:

apply - the function to apply to the input

Returns:

a new StepFunctionBuilder

Since:

1.1.0

See Also:

• StepFunction

sync

public <V> SyncStepFunction<T,V> sync()

Creates a new SyncStepFunction from this builder.

Type Parameters:

V - the type of the result of the function

Returns:

a new SyncStepFunction

Since:

1.1.0

See Also:

• SyncStepFunction

async

public <V> AsyncStepFunction<T,V> async(Supplier<ExecutorService> executorSupplier)

Creates a new AsyncStepFunction from this builder.

Type Parameters:

V - the type of the result of the function

Parameters:

executorSupplier - the supplier of the executor to use for asynchronous computation

Returns:

a new AsyncStepFunction

Since:

1.1.0

See Also:

• AsyncStepFunction

transition

public StepFunctionBuilder<T,R> transition(Function<R,Boolean> condition,
 StepFunctionBuilder<R,?> nextStep)

Adds a transition to this builder.

Parameters:

condition - the condition to check

nextStep - the next step to transition to

Returns:

this builder

Since:

1.1.0

See Also:

• StepFunction

transition

public <V> StepFunctionBuilder<T,R> transition(Function<R,Boolean> condition,
 Function<R,V> mapper,
 StepFunctionBuilder<V,?> nextStep)

Adds a transition to this builder.

Type Parameters:

V - the type of the input of the next step

Parameters:

condition - the condition to check

mapper - the mapper to apply to the result of the previous step

nextStep - the next step to transition to

Returns:

this builder

Since:

1.1.0

See Also:

• StepFunction