Javadocs cosmetics

Author: slinkydeveloper

sdk-api/src/main/java/dev/restate/sdk/Context.java

@@ -56,8 +56,8 @@
  *
  * <h2>Thread safety</h2>
  *
- * This interface MUST NOT be accessed concurrently since it can lead to different orderings of user
- * actions, corrupting the execution of the invocation.
+ * This interface <b>MUST NOT</b> be accessed concurrently since it can lead to different orderings
+ * of user actions, corrupting the execution of the invocation.
  */
 public interface Context {
 
@@ -142,21 +142,6 @@ default DurableFuture<Void> timer(Duration duration) {
    */
   DurableFuture<Void> timer(String name, Duration duration);
 
-  /**
-   * Like {@link #run(String, TypeTag, ThrowingSupplier)}, but using a custom retry policy.
-   *
-   * <p>When a retry policy is not specified, the {@code run} will be retried using the <a
-   * href="https://docs.restate.dev/operate/configuration/server">Restate invoker retry policy</a>,
-   * which by default retries indefinitely.
-   *
-   * @see RetryPolicy
-   */
-  default <T> T run(
-      String name, TypeTag<T> typeTag, RetryPolicy retryPolicy, ThrowingSupplier<T> action)
-      throws TerminalException {
-    return runAsync(name, typeTag, retryPolicy, action).await();
-  }
-
   /**
    * Execute a non-deterministic closure, recording the result value in the journal. The result
    * value will be re-played in case of re-invocation (e.g. because of failure recovery or
@@ -221,6 +206,22 @@ default <T> T run(String name, Class<T> clazz, ThrowingSupplier<T> action)
     return run(name, TypeTag.of(clazz), action);
   }
 
+  /**
+   * Like {@link #run(String, TypeTag, ThrowingSupplier)}, but using a custom retry policy.
+   *
+   * <p>When a retry policy is not specified, the {@code run} will be retried using the <a
+   * href="https://docs.restate.dev/operate/configuration/server">Restate invoker retry policy</a>,
+   * which by default retries indefinitely.
+   *
+   * @see #run(String, Class, ThrowingSupplier)
+   * @see RetryPolicy
+   */
+  default <T> T run(
+      String name, TypeTag<T> typeTag, RetryPolicy retryPolicy, ThrowingSupplier<T> action)
+      throws TerminalException {
+    return runAsync(name, typeTag, retryPolicy, action).await();
+  }
+
   /**
    * Like {@link #run(String, Class, ThrowingSupplier)}, but using a custom retry policy.
    *
@@ -325,7 +326,7 @@ default void run(ThrowingRunnable runnable) throws TerminalException {
    *         .toList();
    *
    * // Await all of them
-   * Awaitable.all(resultFutures).await();
+   * DurableFuture.all(resultFutures).await();
    *
    * // Fan in - Aggregate the results
    * var results = resultFutures.stream()
@@ -477,6 +478,8 @@ default <T> Awakeable<T> awakeable(Class<T> clazz) {
   AwakeableHandle awakeableHandle(String id);
 
   /**
+   * Returns a deterministic random.
+   *
    * @see RestateRandom
    */
   RestateRandom random();