Skip to content

Commit f6acfc8

Browse files
committed
Incorporating Javi's review
Signed-off-by: Ricardo Zanini <ricardozanini@gmail.com>
1 parent dccb303 commit f6acfc8

File tree

2 files changed

+0
-3
lines changed

2 files changed

+0
-3
lines changed

experimental/lambda/src/main/java/io/serverlessworkflow/impl/executors/func/JavaConsumerCallExecutor.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,6 @@ public CompletableFuture<WorkflowModel> apply(
4141
WorkflowContext workflowContext, TaskContext taskContext, WorkflowModel input) {
4242
T typed = JavaFuncUtils.convertT(input, inputClass);
4343
consumer.accept(typed);
44-
4544
return CompletableFuture.completedFuture(input);
4645
}
4746

experimental/lambda/src/main/java/io/serverlessworkflow/impl/executors/func/JavaContextFunctionCallExecutor.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -42,10 +42,8 @@ public void init(CallJava.CallJavaContextFunction<T, V> task, WorkflowDefinition
4242
@Override
4343
public CompletableFuture<WorkflowModel> apply(
4444
WorkflowContext workflowContext, TaskContext taskContext, WorkflowModel input) {
45-
4645
WorkflowModelFactory mf = workflowContext.definition().application().modelFactory();
4746
T typedIn = JavaFuncUtils.convertT(input, inputClass);
48-
4947
V out = function.apply(typedIn, workflowContext);
5048
return CompletableFuture.completedFuture(mf.fromAny(input, out));
5149
}

0 commit comments

Comments
 (0)