Added WorkflowClient.execute (#122)

* Added Retryer.retryAsync

* Introduced IWorkflowService and added getResultAsync

* Added WorkflowClient.execute which returns CompletableFuture with workflow result.

* Added WorkflowClient.execute and its unit test

Author: mfateev

build.gradle

@@ -52,6 +52,7 @@ license {
 }
 
 compileJava {
+    dependsOn 'googleJavaFormat'
     options.encoding = 'UTF-8'
     options.compilerArgs << "-Xlint:unchecked" << "-Xlint:deprecation" << "-XepExcludedPaths:" +
             ".*/generated-sources/.*"
@@ -62,7 +63,6 @@ license {
     exclude '**/com/uber/cadence/*.java'
 }
 
-
 compileTestJava {
     options.encoding = 'UTF-8'
     options.compilerArgs << "-Xlint:unchecked" << "-Xlint:deprecation" << "-XepExcludedPaths:" +

src/main/java/com/uber/cadence/activity/Activity.java

@@ -17,9 +17,9 @@
 
 package com.uber.cadence.activity;
 
-import com.uber.cadence.WorkflowService;
 import com.uber.cadence.internal.sync.ActivityInternal;
 import com.uber.cadence.internal.sync.WorkflowInternal;
+import com.uber.cadence.serviceclient.IWorkflowService;
 import com.uber.cadence.workflow.ActivityException;
 import com.uber.cadence.workflow.ActivityTimeoutException;
 import java.util.concurrent.CancellationException;
@@ -76,7 +76,7 @@ public static void heartbeat(Object details) throws CancellationException {
    *     operations like sending signal to its parent workflow. @TODO getWorkflowClient method to
    *     hide the service.
    */
-  public static WorkflowService.Iface getService() {
+  public static IWorkflowService getService() {
     return ActivityInternal.getService();
   }
 

src/main/java/com/uber/cadence/client/UntypedWorkflowStub.java

@@ -18,6 +18,7 @@
 package com.uber.cadence.client;
 
 import com.uber.cadence.WorkflowExecution;
+import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.TimeoutException;
 
@@ -27,6 +28,8 @@ public interface UntypedWorkflowStub {
 
   WorkflowExecution start(Object... args);
 
+  String getWorkflowType();
+
   WorkflowExecution getExecution();
 
   /**
@@ -39,6 +42,8 @@ public interface UntypedWorkflowStub {
    */
   <R> R getResult(Class<R> returnType);
 
+  <R> CompletableFuture<R> getResultAsync(Class<R> returnType);
+
   /**
    * Returns workflow result potentially waiting for workflow to complete. Behind the scene this
    * call performs long poll on Cadence service waiting for workflow completion notification.
@@ -52,6 +57,8 @@ public interface UntypedWorkflowStub {
    */
   <R> R getResult(long timeout, TimeUnit unit, Class<R> returnType) throws TimeoutException;
 
+  <R> CompletableFuture<R> getResultAsync(long timeout, TimeUnit unit, Class<R> returnType);
+
   <R> R query(String queryType, Class<R> returnType, Object... args);
 
   /** Request cancellation. */