Package io.serverlessworkflow.impl.executors.func

Class AbstractJavaCallExecutor<T,V>

java.lang.Object

io.serverlessworkflow.impl.executors.func.AbstractJavaCallExecutor<T,V>

All Implemented Interfaces:

io.serverlessworkflow.impl.executors.CallableTask

Direct Known Subclasses:

JavaContextFunctionCallExecutor, JavaFilterFunctionCallExecutor, JavaFunctionCallExecutor, JavaLoopFunctionCallExecutor, JavaLoopFunctionIndexCallExecutor

public abstract class AbstractJavaCallExecutor<T,V>
extends Object
implements io.serverlessworkflow.impl.executors.CallableTask

Field Summary

Fields

Modifier and Type	Field	Description
protected final Optional<Class<T>>	inputClass

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractJavaCallExecutor()
protected	AbstractJavaCallExecutor(Optional<Class<T>> inputClass, Optional<Class<V>> outputClass)

Method Summary

Modifier and Type	Method	Description
CompletableFuture<io.serverlessworkflow.impl.WorkflowModel>	apply(io.serverlessworkflow.impl.WorkflowContext workflowContext, io.serverlessworkflow.impl.TaskContext taskContext, io.serverlessworkflow.impl.WorkflowModel input)
protected abstract V	callJavaFunction(io.serverlessworkflow.impl.WorkflowContext workflowContext, io.serverlessworkflow.impl.TaskContext taskContext, T input)
protected Object	convertResponse(Object obj)
protected Object	convertTypedResponse(V obj)
protected T	model2Input(io.serverlessworkflow.impl.WorkflowModel model)
protected io.serverlessworkflow.impl.WorkflowModel	output2Model(io.serverlessworkflow.impl.WorkflowModelFactory modelFactory, io.serverlessworkflow.impl.WorkflowModel input, Object result)

Methods inherited from class java.lang.Object

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

Field Details

inputClass

protected final Optional<Class<T>> inputClass

Constructor Details

AbstractJavaCallExecutor

protected AbstractJavaCallExecutor()

AbstractJavaCallExecutor

protected AbstractJavaCallExecutor(Optional<Class<T>> inputClass,
 Optional<Class<V>> outputClass)

Method Details

apply

public CompletableFuture<io.serverlessworkflow.impl.WorkflowModel> apply(io.serverlessworkflow.impl.WorkflowContext workflowContext,
 io.serverlessworkflow.impl.TaskContext taskContext,
 io.serverlessworkflow.impl.WorkflowModel input)

Specified by:

apply in interface io.serverlessworkflow.impl.executors.CallableTask

callJavaFunction

protected abstract V callJavaFunction(io.serverlessworkflow.impl.WorkflowContext workflowContext,
 io.serverlessworkflow.impl.TaskContext taskContext,
 T input)

model2Input

protected T model2Input(io.serverlessworkflow.impl.WorkflowModel model)

convertTypedResponse

protected Object convertTypedResponse(V obj)

convertResponse

protected Object convertResponse(Object obj)

output2Model

protected io.serverlessworkflow.impl.WorkflowModel output2Model(io.serverlessworkflow.impl.WorkflowModelFactory modelFactory,
 io.serverlessworkflow.impl.WorkflowModel input,
 Object result)