Add duration option to await

Signed-off-by: Greg Haskins <[email protected]>

Author: ghaskins

project.clj

@@ -27,5 +27,5 @@
   :cloverage {:runner :eftest
               :runner-opts {:multithread? false
                             :fail-fast? true}
-              :fail-threshold 92
+              :fail-threshold 91
               :ns-exclude-regex [#"temporal.client.worker"]})

src/temporal/core.clj

@@ -4,10 +4,15 @@
   (:import [io.temporal.workflow Workflow]
            [java.util.function Supplier]))
 
+(defn- ->supplier
+  [f]
+  (reify Supplier
+    (get [_]
+      (f))))
+
 (defn await
   "Efficiently parks the workflow until 'pred' evaluates to true.  Re-evaluates on each state transition"
-  [pred]
-  (Workflow/await
-   (reify Supplier
-     (get [_]
-       (pred)))))
+  ([pred]
+   (Workflow/await (->supplier pred)))
+  ([duration pred]
+   (Workflow/await duration (->supplier pred))))