removed executeTaskAsync method

Author: antmendoza

core/src/main/java/io/temporal/samples/taskinteraction/TaskService.java

@@ -21,7 +21,6 @@
 
 import com.fasterxml.jackson.annotation.JsonIgnore;
 import io.temporal.workflow.CompletablePromise;
-import io.temporal.workflow.Promise;
 import io.temporal.workflow.Workflow;
 import java.util.Collections;
 import java.util.HashMap;
@@ -74,10 +73,6 @@ public TaskService() {
   private final Logger logger = Workflow.getLogger(TaskService.class);
 
   public R executeTask(Callback<R> callback, String token) {
-    return executeTaskAsync(callback, token).get();
-  }
-
-  public Promise<R> executeTaskAsync(Callback<R> callback, String token) {
 
     final Task task = new Task(token);
     logger.info("Before creating task : " + task);
@@ -88,7 +83,7 @@ public Promise<R> executeTaskAsync(Callback<R> callback, String token) {
     final CompletablePromise<R> promise = Workflow.newPromise();
     pendingPromises.put(token, promise);
 
-    return promise;
+    return promise.get();
   }
 
   public List<Task> getOpenTasks() {

core/src/main/java/io/temporal/samples/taskinteraction/TaskWorkflowImpl.java

@@ -20,6 +20,7 @@
 package io.temporal.samples.taskinteraction;
 
 import io.temporal.activity.ActivityOptions;
+import io.temporal.workflow.Async;
 import io.temporal.workflow.Promise;
 import io.temporal.workflow.Workflow;
 import java.time.Duration;
@@ -45,9 +46,14 @@ public void execute() {
     // to change the task state, and ultimately to complete the task
     logger.info("About to create async tasks");
     final Promise<String> task1 =
-        taskService.executeTaskAsync(() -> activity.createTask("TODO 1"), taskToken.getNext());
+        Async.function(
+            () ->
+                taskService.executeTask(() -> activity.createTask("TODO 1"), taskToken.getNext()));
+
     final Promise<String> task2 =
-        taskService.executeTaskAsync(() -> activity.createTask("TODO 2"), taskToken.getNext());
+        Async.function(
+            () ->
+                taskService.executeTask(() -> activity.createTask("TODO 2"), taskToken.getNext()));
 
     logger.info("Awaiting for two tasks to get completed");
     // Block execution until both tasks complete